public class FlowConnectorProps extends Props
FlowConnector
specific
properties through the FlowConnector
constructor.AppProps
,
CascadeProps
,
FlowProps
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ASSERTION_LEVEL |
static java.lang.String |
CHECKPOINT_TAP_DECORATOR_CLASS |
static java.lang.String |
DEBUG_LEVEL |
static java.lang.String |
ENABLE_DECORATE_ACCUMULATED_TAP |
static java.lang.String |
INTERMEDIATE_SCHEME_CLASS |
static java.lang.String |
TEMPORARY_TAP_DECORATOR_CLASS |
Constructor and Description |
---|
FlowConnectorProps() |
Modifier and Type | Method and Description |
---|---|
protected void |
addPropertiesTo(java.util.Properties properties) |
static FlowConnectorProps |
flowConnectorProps()
Creates a new FlowConnectorProps instance.
|
AssertionLevel |
getAssertionLevel() |
java.lang.String |
getCheckpointTapDecoratorClassName() |
DebugLevel |
getDebugLevel() |
java.lang.Boolean |
getEnableDecorateAccumulatedTap() |
java.lang.String |
getIntermediateSchemeClassName() |
java.lang.String |
getTemporaryTapDecoratorClassName() |
FlowConnectorProps |
setAssertionLevel(AssertionLevel assertionLevel)
Method setAssertionLevel sets the target planner
AssertionLevel . |
static void |
setAssertionLevel(java.util.Map<java.lang.Object,java.lang.Object> properties,
AssertionLevel assertionLevel)
Method setAssertionLevel sets the target planner
AssertionLevel . |
static void |
setCheckpointTapDecoratorClass(java.util.Map<java.lang.Object,java.lang.Object> properties,
java.lang.String checkpointTapDecoratorClassName)
Method checkpointTapDecoratorClassName is used for wrapping a checkpoint Tap.
|
FlowConnectorProps |
setCheckpointTapDecoratorClassName(java.lang.Class<DecoratorTap> checkpointTapDecoratorClass)
Method setCheckpointTapDecoratorClassName sets the class of a
DecoratorTap to use to
wrap an Checkpoint Tap instance within the Flow. |
FlowConnectorProps |
setCheckpointTapDecoratorClassName(java.lang.String checkpointTapDecoratorClassName)
Method setCheckpointTapDecoratorClassName sets the class of a
DecoratorTap to use to
wrap an Checkpoint Tap instance within the Flow. |
FlowConnectorProps |
setDebugLevel(DebugLevel debugLevel)
Method setDebugLevel sets the target planner
DebugLevel . |
static void |
setDebugLevel(java.util.Map<java.lang.Object,java.lang.Object> properties,
DebugLevel debugLevel)
Method setDebugLevel sets the target planner
DebugLevel . |
FlowConnectorProps |
setEnableDecorateAccumulatedTap(boolean enableDecorateAccumulatedTap)
Method setEnableDecorateAccumulatedTap, when set to
false , disables the use of a DistCacheTap decorator
implementation during planning. |
static void |
setIntermediateSchemeClass(java.util.Map<java.lang.Object,java.lang.Object> properties,
java.lang.Class<? extends Scheme> intermediateSchemeClass)
Method setIntermediateSchemeClass is used for debugging.
|
static void |
setIntermediateSchemeClass(java.util.Map<java.lang.Object,java.lang.Object> properties,
java.lang.String intermediateSchemeClassName)
Method setIntermediateSchemeClass is used for debugging.
|
FlowConnectorProps |
setIntermediateSchemeClassName(java.lang.Class<Scheme> intermediateSchemeClass)
Method setIntermediateSchemeClassName is used for debugging.
|
FlowConnectorProps |
setIntermediateSchemeClassName(java.lang.String intermediateSchemeClassName)
Method setIntermediateSchemeClassName is used for debugging.
|
static void |
setTemporaryTapDecoratorClass(java.util.Map<java.lang.Object,java.lang.Object> properties,
java.lang.String temporaryTapDecoratorClassName)
Method temporaryTapDecoratorClassName is used for wrapping a intermediate temporary Tap.
|
FlowConnectorProps |
setTemporaryTapDecoratorClassName(java.lang.Class<DecoratorTap> temporaryTapDecoratorClass)
Method setTemporaryTapDecoratorClassName sets the class of a
DecoratorTap to use to
wrap an intermediate temporary Tap instance internal to the Flow. |
FlowConnectorProps |
setTemporaryTapDecoratorClassName(java.lang.String temporaryTapDecoratorClassName)
Method setTemporaryTapDecoratorClassName sets the class of a
DecoratorTap to use to
wrap an intermediate temporary Tap instance internal to the Flow. |
buildProperties, buildProperties, buildProperties, buildProperties, setProperties, setProperties
public static final java.lang.String ASSERTION_LEVEL
public static final java.lang.String DEBUG_LEVEL
public static final java.lang.String INTERMEDIATE_SCHEME_CLASS
public static final java.lang.String TEMPORARY_TAP_DECORATOR_CLASS
public static final java.lang.String CHECKPOINT_TAP_DECORATOR_CLASS
public static final java.lang.String ENABLE_DECORATE_ACCUMULATED_TAP
public FlowConnectorProps()
public static void setAssertionLevel(java.util.Map<java.lang.Object,java.lang.Object> properties, AssertionLevel assertionLevel)
AssertionLevel
.properties
- of type MapassertionLevel
- of type AssertionLevelpublic static void setDebugLevel(java.util.Map<java.lang.Object,java.lang.Object> properties, DebugLevel debugLevel)
DebugLevel
.properties
- of type MapdebugLevel
- of type DebugLevelpublic static void setIntermediateSchemeClass(java.util.Map<java.lang.Object,java.lang.Object> properties, java.lang.Class<? extends Scheme> intermediateSchemeClass)
properties
- of type MapintermediateSchemeClass
- of type Classpublic static void setIntermediateSchemeClass(java.util.Map<java.lang.Object,java.lang.Object> properties, java.lang.String intermediateSchemeClassName)
properties
- of type MapintermediateSchemeClassName
- of type Stringpublic static void setTemporaryTapDecoratorClass(java.util.Map<java.lang.Object,java.lang.Object> properties, java.lang.String temporaryTapDecoratorClassName)
properties
- of type MaptemporaryTapDecoratorClassName
- of type Stringpublic static void setCheckpointTapDecoratorClass(java.util.Map<java.lang.Object,java.lang.Object> properties, java.lang.String checkpointTapDecoratorClassName)
properties
- of type MapcheckpointTapDecoratorClassName
- of type Stringpublic static FlowConnectorProps flowConnectorProps()
public AssertionLevel getAssertionLevel()
public FlowConnectorProps setAssertionLevel(AssertionLevel assertionLevel)
AssertionLevel
.assertionLevel
- of type AssertionLevelpublic DebugLevel getDebugLevel()
public FlowConnectorProps setDebugLevel(DebugLevel debugLevel)
DebugLevel
.debugLevel
- of type DebugLevelpublic java.lang.String getIntermediateSchemeClassName()
public FlowConnectorProps setIntermediateSchemeClassName(java.lang.String intermediateSchemeClassName)
intermediateSchemeClassName
- of type Stringpublic FlowConnectorProps setIntermediateSchemeClassName(java.lang.Class<Scheme> intermediateSchemeClass)
intermediateSchemeClass
- of type Classpublic java.lang.String getTemporaryTapDecoratorClassName()
public FlowConnectorProps setTemporaryTapDecoratorClassName(java.lang.String temporaryTapDecoratorClassName)
DecoratorTap
to use to
wrap an intermediate temporary Tap instance internal to the Flow.temporaryTapDecoratorClassName
- of type Stringpublic FlowConnectorProps setTemporaryTapDecoratorClassName(java.lang.Class<DecoratorTap> temporaryTapDecoratorClass)
DecoratorTap
to use to
wrap an intermediate temporary Tap instance internal to the Flow.temporaryTapDecoratorClass
- of type Classpublic java.lang.String getCheckpointTapDecoratorClassName()
public FlowConnectorProps setCheckpointTapDecoratorClassName(java.lang.String checkpointTapDecoratorClassName)
DecoratorTap
to use to
wrap an Checkpoint Tap instance within the Flow.checkpointTapDecoratorClassName
- of type Stringpublic FlowConnectorProps setCheckpointTapDecoratorClassName(java.lang.Class<DecoratorTap> checkpointTapDecoratorClass)
DecoratorTap
to use to
wrap an Checkpoint Tap instance within the Flow.checkpointTapDecoratorClass
- of type Classpublic java.lang.Boolean getEnableDecorateAccumulatedTap()
public FlowConnectorProps setEnableDecorateAccumulatedTap(boolean enableDecorateAccumulatedTap)
false
, disables the use of a DistCacheTap decorator
implementation during planning. It is enabled by default.
When enabled, any Tap
instance declared or planned via the planner (intermediate Tap or binding
a Checkpoint
pipe to a tap -- when applicable) will be wrapped by a platform specific
implementation of a Tap that allows for data reads from the platform provided distributed caches or similiar
service, if any.
enableDecorateAccumulatedTap
- the enableDecorateAccumulatedTap of type booleanprotected void addPropertiesTo(java.util.Properties properties)
addPropertiesTo
in class Props
Copyright © 2007-2015 Xplenty, Inc. All Rights Reserved.