AvroGenericRecordBolt |
AvroGenericRecordBolt.addRotationAction(RotationAction action) |
AvroGenericRecordBolt |
AvroGenericRecordBolt.withConfigKey(String configKey) |
AvroGenericRecordBolt |
AvroGenericRecordBolt.withFileNameFormat(FileNameFormat fileNameFormat) |
AvroGenericRecordBolt |
AvroGenericRecordBolt.withFsUrl(String fsUrl) |
AvroGenericRecordBolt |
AvroGenericRecordBolt.withMaxOpenFiles(int maxOpenFiles) |
AvroGenericRecordBolt |
AvroGenericRecordBolt.withPartitioner(Partitioner partitioner) |
AvroGenericRecordBolt |
AvroGenericRecordBolt.withRotationPolicy(FileRotationPolicy rotationPolicy) |
AvroGenericRecordBolt |
AvroGenericRecordBolt.withSyncPolicy(SyncPolicy syncPolicy) |
AvroGenericRecordBolt |
AvroGenericRecordBolt.withTickTupleIntervalSeconds(int interval) |