Interface OutputFormatFactory<T>

  • Type Parameters:
    T - The type of the consumed records.
    All Superinterfaces:
    Serializable

    @Internal
    public interface OutputFormatFactory<T>
    extends Serializable
    A factory to create an OutputFormat.
    • Method Detail

      • createOutputFormat

        org.apache.flink.api.common.io.OutputFormat<T> createOutputFormat​(org.apache.flink.core.fs.Path path)
        Create a OutputFormat with specific path.