Package com.hazelcast.pc

Class PipelineCreator

java.lang.Object

com.hazelcast.pc.PipelineCreator

public class PipelineCreator
extends Object

Method Summary

Modifier and Type	Method	Description
Pipeline	createPipeline()
static PipelineCreator	fromConfig(JetConfig config)
static PipelineCreator	fromConfigWithBaseDir(JetConfig config, Path baseDir)
static void	registerSink(String type, Sink sink)
static void	registerSource(String type, Source source)
static void	registerTransform(String type, Transform transform)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

fromConfig

public static PipelineCreator fromConfig(JetConfig config)

fromConfigWithBaseDir

public static PipelineCreator fromConfigWithBaseDir(@Nonnull
 JetConfig config,
 Path baseDir)

createPipeline

public Pipeline createPipeline()

registerSource

public static void registerSource(String type,
 Source source)

registerSink

public static void registerSink(String type,
 Sink sink)

registerTransform

public static void registerTransform(String type,
 Transform transform)