Interface | Description |
---|---|
Bucketer |
A bucketer is used with a
RollingSink
to put emitted elements into rolling files. |
Clock |
A clock that can provide the current time.
|
Writer<T> |
An implementation of
Writer is used in conjunction with a
RollingSink to perform the actual
writing to the bucket files. |
Class | Description |
---|---|
AvroKeyValueSinkWriter<K,V> |
Implementation of AvroKeyValue writer that can be used in Sink.
|
AvroKeyValueSinkWriter.AvroKeyValue<K,V> | |
DateTimeBucketer |
A
Bucketer that assigns to buckets based on current system time. |
NonRollingBucketer |
A
Bucketer that does not perform any
rolling of files. |
RollingSink<T> |
Sink that emits its input elements to rolling
FileSystem files. |
SequenceFileWriter<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable> |
A
Writer that writes the bucket files as Hadoop SequenceFiles . |
StreamWriterBase<T> |
Base class for
Writers that write to a FSDataOutputStream . |
StringWriter<T> |
A
Writer that uses toString() on the input elements and writes them to
the output bucket file separated by newline. |
SystemClock |
A
Clock that uses System.currentTimeMillis() to determine the system time. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.