Package io.druid.segment.indexing

Examples of io.druid.segment.indexing.RealtimeIOConfig

68
69
70
71
72
73
74
75
76
77
78
            new AggregatorFactory[]{
                new CountAggregatorFactory("count")
            },
            new UniformGranularitySpec(Granularity.HOUR, QueryGranularity.MINUTE, null, Granularity.HOUR)
        ),
        new RealtimeIOConfig(
            null,
            new RealtimePlumberSchool(
                null, null, null, null, null, null, null, null, null, null, null, null, null, 0
            )
        ),
View Full Code Here
132
133
134
135
136
137
138
139
140
141
142
              spec.getDataSource(),
              firehoseFactory == null ? null : firehoseFactory.getParser(),
              spec.getAggregators(),
              new UniformGranularitySpec(segmentGranularity, spec.getIndexGranularity(), null, segmentGranularity)
          ),
          new RealtimeIOConfig(firehoseFactory, null),
          new RealtimeTuningConfig(
              fireDepartmentConfig == null ? null : fireDepartmentConfig.getMaxRowsInMemory(),
              fireDepartmentConfig == null ? null : fireDepartmentConfig.getIntermediatePersistPeriod(),
              windowPeriod,
              null,
View Full Code Here
280
281
282
283
284
285
286
287
288
289
290
        }
      }
    };

    DataSchema dataSchema = spec.getDataSchema();
    RealtimeIOConfig realtimeIOConfig = spec.getIOConfig();
    RealtimeTuningConfig tuningConfig = spec.getTuningConfig()
                                              .withBasePersistDirectory(new File(toolbox.getTaskWorkDir(), "persist"))
                                              .withVersioningPolicy(versioningPolicy);

    final FireDepartment fireDepartment = new FireDepartment(
View Full Code Here
74
75
76
77
78
79
80
81
82
83
84
        "test",
        null,
        new AggregatorFactory[]{new CountAggregatorFactory("rows")},
        new UniformGranularitySpec(Granularity.HOUR, QueryGranularity.NONE, null, Granularity.HOUR)
    );
    RealtimeIOConfig ioConfig = new RealtimeIOConfig(
        new FirehoseFactory()
        {
          @Override
          public Firehose connect(InputRowParser parser) throws IOException
          {
View Full Code Here
82
83
84
85
86
87
88
89
90
91
92
              schema.getIndexGranularity(),
              Lists.<Interval>newArrayList(),
              plumberSchool.getSegmentGranularity()
          )
      );
      this.ioConfig = new RealtimeIOConfig(
          firehoseFactory,
          plumberSchool
      );
      this.tuningConfig = new RealtimeTuningConfig(
          config.getMaxRowsInMemory(),
View Full Code Here
TOP

Related Classes of io.druid.segment.indexing.RealtimeIOConfig

  • io.druid.indexing.common.task.RealtimeIndexTask
  • io.druid.segment.realtime.FireDepartment
  • io.druid.segment.realtime.FireDepartmentTest
  • io.druid.segment.realtime.RealtimeManagerTest
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.