Package | Description |
---|---|
org.apache.flink.streaming.connectors.fs | |
org.apache.flink.streaming.connectors.fs.bucketing | |
org.apache.flink.streaming.tests |
Class and Description |
---|
AvroKeyValueSinkWriter
Implementation of AvroKeyValue writer that can be used in Sink.
|
Bucketer
Deprecated.
use
Bucketer instead. |
Clock
A clock that can provide the current time.
|
RollingSink
Deprecated.
use
BucketingSink instead. |
SequenceFileWriter
A
Writer that writes the bucket files as Hadoop SequenceFiles . |
StreamWriterBase
Base class for
Writers that write to a FSDataOutputStream . |
StringWriter
A
Writer that uses toString() on the input elements and writes them to
the output bucket file separated by newline. |
Writer
An implementation of
Writer is used in conjunction with a
BucketingSink to perform the actual
writing to the bucket files. |
Class and Description |
---|
Clock
A clock that can provide the current time.
|
Writer
An implementation of
Writer is used in conjunction with a
BucketingSink to perform the actual
writing to the bucket files. |
Class and Description |
---|
Clock
A clock that can provide the current time.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.