OUT
- The output type of the operator@Internal public class SimpleInputFormatOperatorFactory<OUT> extends SimpleOperatorFactory<OUT> implements InputFormatOperatorFactory<OUT>
StreamSource
.Constructor and Description |
---|
SimpleInputFormatOperatorFactory(StreamSource<OUT,InputFormatSourceFunction<OUT>> operator) |
Modifier and Type | Method and Description |
---|---|
InputFormat<OUT,InputSplit> |
getInputFormat() |
createStreamOperator, getChainingStrategy, getOperator, isInputTypeConfigurable, isOperatorSelectiveReading, isOutputTypeConfigurable, isStreamSource, of, setChainingStrategy, setInputType, setOutputType
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
createStreamOperator, getChainingStrategy, isInputTypeConfigurable, isOperatorSelectiveReading, isOutputTypeConfigurable, isStreamSource, setChainingStrategy, setInputType, setOutputType
public SimpleInputFormatOperatorFactory(StreamSource<OUT,InputFormatSourceFunction<OUT>> operator)
public InputFormat<OUT,InputSplit> getInputFormat()
getInputFormat
in interface InputFormatOperatorFactory<OUT>
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.