public class Splice extends Pipe
GroupBy
,
CoGroup
,
Merge
,
HashJoin
,
Serialized FormModifier and Type | Field and Description |
---|---|
protected Fields |
declaredFields
Field declaredFields
|
protected Map<String,Fields> |
keyFieldsMap
Field groupFieldsMap
|
protected Fields |
resultGroupFields
Field resultGroupFields
|
protected Map<String,Fields> |
sortFieldsMap
Field sortFieldsMap
|
configDef, name, nodeConfigDef, parent, previous, stepConfigDef
Modifier | Constructor and Description |
---|---|
protected |
Splice(Pipe... pipes)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe pipe)
Constructor Splice creates a new Splice instance where grouping occurs on
Fields.ALL fields. |
protected |
Splice(Pipe[] pipes,
Fields groupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe[] pipes,
Fields[] groupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe[] pipes,
Fields[] groupFields,
Fields declaredFields,
Fields resultGroupFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe[] pipes,
Fields[] groupFields,
Fields declaredFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe[] pipes,
Fields groupFields,
Fields sortFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe[] pipes,
Fields groupFields,
Fields sortFields,
boolean reverseOrder)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe pipe,
Fields groupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe pipe,
Fields groupFields,
Fields sortFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe pipe,
Fields groupFields,
Fields sortFields,
boolean reverseOrder)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe pipe,
Fields groupFields,
int numSelfJoins)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe pipe,
Fields groupFields,
int numSelfJoins,
Fields declaredFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe pipe,
Fields groupFields,
int numSelfJoins,
Fields declaredFields,
Fields resultGroupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe pipe,
Fields groupFields,
int numSelfJoins,
Fields declaredFields,
Fields resultGroupFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe pipe,
Fields groupFields,
int numSelfJoins,
Fields declaredFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe pipe,
Fields groupFields,
int numSelfJoins,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe lhs,
Fields lhsGroupFields,
Pipe rhs,
Fields rhsGroupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe lhs,
Fields lhsGroupFields,
Pipe rhs,
Fields rhsGroupFields,
Fields declaredFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe lhs,
Fields lhsGroupFields,
Pipe rhs,
Fields rhsGroupFields,
Fields declaredFields,
Fields resultGroupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe lhs,
Fields lhsGroupFields,
Pipe rhs,
Fields rhsGroupFields,
Fields declaredFields,
Fields resultGroupFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe lhs,
Fields lhsGroupFields,
Pipe rhs,
Fields rhsGroupFields,
Fields declaredFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(Pipe lhs,
Fields lhsGroupFields,
Pipe rhs,
Fields rhsGroupFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe... pipes)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe[] pipes,
Fields groupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe[] pipes,
Fields[] groupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe[] pipes,
Fields[] groupFields,
Fields declaredFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe[] pipes,
Fields[] groupFields,
Fields declaredFields,
Fields resultGroupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe[] pipes,
Fields[] groupFields,
Fields declaredFields,
Fields resultGroupFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe[] pipe,
Fields groupFields,
Fields sortFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe[] pipes,
Fields groupFields,
Fields sortFields,
boolean reverseOrder)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe pipe,
Fields groupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe pipe,
Fields groupFields,
Fields sortFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe pipe,
Fields groupFields,
Fields sortFields,
boolean reverseOrder)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe pipe,
Fields groupFields,
int numSelfJoins)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe pipe,
Fields groupFields,
int numSelfJoins,
Fields declaredFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe pipe,
Fields groupFields,
int numSelfJoins,
Fields declaredFields,
Fields resultGroupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe pipe,
Fields groupFields,
int numSelfJoins,
Fields declaredFields,
Fields resultGroupFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe pipe,
Fields groupFields,
int numSelfJoins,
Fields declaredFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe pipe,
Fields groupFields,
int numSelfJoins,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe lhs,
Fields lhsGroupFields,
Pipe rhs,
Fields rhsGroupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe lhs,
Fields lhsGroupFields,
Pipe rhs,
Fields rhsGroupFields,
Fields declaredFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe lhs,
Fields lhsGroupFields,
Pipe rhs,
Fields rhsGroupFields,
Fields declaredFields,
Fields resultGroupFields)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe lhs,
Fields lhsGroupFields,
Pipe rhs,
Fields rhsGroupFields,
Fields declaredFields,
Fields resultGroupFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe lhs,
Fields lhsGroupFields,
Pipe rhs,
Fields rhsGroupFields,
Fields declaredFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
protected |
Splice(String spliceName,
Pipe lhs,
Fields lhsGroupFields,
Pipe rhs,
Fields rhsGroupFields,
Joiner joiner)
Constructor Splice creates a new Splice instance.
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object object) |
Fields |
getDeclaredFields()
Method getDeclaredFields returns the declaredFields of this Splice object.
|
Fields |
getJoinDeclaredFields() |
Joiner |
getJoiner() |
Map<String,Fields> |
getKeySelectors()
Method getGroupingSelectors returns the groupingSelectors of this Splice object.
|
String |
getName()
Get the name of this pipe.
|
int |
getNumSelfJoins() |
Map<String,Integer> |
getPipePos() |
Pipe[] |
getPrevious()
Get all the upstream pipes this pipe is connected to.
|
Map<String,Fields> |
getSortingSelectors()
Method getSortingSelectors returns the sortingSelectors of this Splice object.
|
int |
hashCode() |
boolean |
isCoGroup() |
boolean |
isEquivalentTo(FlowElement element) |
boolean |
isGroupBy()
Method isGroupBy returns true if this Splice instance will perform a GroupBy operation.
|
boolean |
isJoin() |
boolean |
isMerge() |
boolean |
isSelfJoin() |
boolean |
isSorted()
Method isSorted returns true if this Splice instance is sorting values other than the group fields.
|
boolean |
isSortReversed()
Method isSortReversed returns true if sorting is reversed.
|
Scope |
outgoingScopeFor(Set<Scope> incomingScopes)
Method outgoingScopeFor returns the Scope this FlowElement hands off to the next FlowElement.
|
protected void |
printInternal(StringBuffer buffer,
Scope scope) |
Fields |
resolveIncomingOperationPassThroughFields(Scope incomingScope)
Method resolveIncomingOperationPassThroughFields returns the Fields outgoing from the previous FlowElement that
are consumable by this FlowElement when preparing the Pipe outgoing tuple.
|
String |
toString() |
getConfigDef, getHeads, getNodeConfigDef, getParent, getStepConfigDef, getTrace, hasConfigDef, hasNodeConfigDef, hasStepConfigDef, id, named, names, pipes, print, resolveIncomingOperationArgumentFields, setParent
protected final Map<String,Fields> keyFieldsMap
protected Map<String,Fields> sortFieldsMap
protected Fields declaredFields
protected Fields resultGroupFields
protected Splice(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields)
lhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type Fieldsprotected Splice(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields, Fields resultGroupFields)
lhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type FieldsresultGroupFields
- of type Fieldsprotected Splice(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields, Joiner joiner)
lhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type Fieldsjoiner
- of type CoGrouperprotected Splice(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
lhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type FieldsresultGroupFields
- of type Fieldsjoiner
- of type Joinerprotected Splice(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Joiner joiner)
lhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type Fieldsjoiner
- of type CoGrouperprotected Splice(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields)
lhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type Fieldsprotected Splice(Pipe... pipes)
pipes
- of type Pipe...protected Splice(Pipe[] pipes, Fields[] groupFields)
pipes
- of type Pipe[]groupFields
- of type Fields[]protected Splice(String spliceName, Pipe[] pipes, Fields[] groupFields)
spliceName
- of type Stringpipes
- of type Pipe[]groupFields
- of type Fields[]protected Splice(String spliceName, Pipe[] pipes, Fields[] groupFields, Fields declaredFields)
spliceName
- of type Stringpipes
- of type Pipe[]groupFields
- of type Fields[]declaredFields
- of type Fieldsprotected Splice(String spliceName, Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Fields resultGroupFields)
spliceName
- of type Stringpipes
- of type Pipe[]groupFields
- of type Fields[]declaredFields
- of type FieldsresultGroupFields
- of type Fieldsprotected Splice(Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Joiner joiner)
pipes
- of type Pipe[]groupFields
- of type Fields[]declaredFields
- of type Fieldsjoiner
- of type CoGrouperprotected Splice(Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
pipes
- of type Pipe[]groupFields
- of type Fields[]declaredFields
- of type FieldsresultGroupFields
- of type Fieldsjoiner
- of type Joinerprotected Splice(String spliceName, Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
spliceName
- of type Stringpipes
- of type Pipe[]groupFields
- of type Fields[]declaredFields
- of type Fieldsjoiner
- of type CoGrouperprotected Splice(String spliceName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields)
spliceName
- of type Stringlhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type Fieldsprotected Splice(String spliceName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields, Fields resultGroupFields)
spliceName
- of type Stringlhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type FieldsresultGroupFields
- of type Fieldsprotected Splice(String spliceName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields, Joiner joiner)
spliceName
- of type Stringlhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type Fieldsjoiner
- of type CoGrouperprotected Splice(String spliceName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
spliceName
- of type Stringlhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type FieldsresultGroupFields
- of type Fieldsjoiner
- of type Joinerprotected Splice(String spliceName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Joiner joiner)
spliceName
- of type Stringlhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type Fieldsjoiner
- of type CoGrouperprotected Splice(String spliceName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields)
spliceName
- of type Stringlhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type Fieldsprotected Splice(String spliceName, Pipe... pipes)
spliceName
- of type Stringpipes
- of type Pipe...protected Splice(Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields)
pipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type Fieldsprotected Splice(Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Fields resultGroupFields)
pipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type FieldsresultGroupFields
- of type Fieldsprotected Splice(Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Joiner joiner)
pipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type Fieldsjoiner
- of type CoGrouperprotected Splice(Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
pipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type FieldsresultGroupFields
- of type Fieldsjoiner
- of type Joinerprotected Splice(Pipe pipe, Fields groupFields, int numSelfJoins, Joiner joiner)
pipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intjoiner
- of type CoGrouperprotected Splice(Pipe pipe, Fields groupFields, int numSelfJoins)
pipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intprotected Splice(String spliceName, Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields)
spliceName
- of type Stringpipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type Fieldsprotected Splice(String spliceName, Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Fields resultGroupFields)
spliceName
- of type Stringpipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type FieldsresultGroupFields
- of type Fieldsprotected Splice(String spliceName, Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Joiner joiner)
spliceName
- of type Stringpipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type Fieldsjoiner
- of type CoGrouperprotected Splice(String spliceName, Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
spliceName
- of type Stringpipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type FieldsresultGroupFields
- of type Fieldsjoiner
- of type Joinerprotected Splice(String spliceName, Pipe pipe, Fields groupFields, int numSelfJoins, Joiner joiner)
spliceName
- of type Stringpipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intjoiner
- of type CoGrouperprotected Splice(String spliceName, Pipe pipe, Fields groupFields, int numSelfJoins)
spliceName
- of type Stringpipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intprotected Splice(Pipe pipe)
Fields.ALL
fields.pipe
- of type Pipeprotected Splice(Pipe pipe, Fields groupFields)
pipe
- of type PipegroupFields
- of type Fieldsprotected Splice(String spliceName, Pipe pipe, Fields groupFields)
spliceName
- of type Stringpipe
- of type PipegroupFields
- of type Fieldsprotected Splice(Pipe pipe, Fields groupFields, Fields sortFields)
pipe
- of type PipegroupFields
- of type FieldssortFields
- of type Fieldsprotected Splice(String spliceName, Pipe pipe, Fields groupFields, Fields sortFields)
spliceName
- of type Stringpipe
- of type PipegroupFields
- of type FieldssortFields
- of type Fieldsprotected Splice(Pipe pipe, Fields groupFields, Fields sortFields, boolean reverseOrder)
pipe
- of type PipegroupFields
- of type FieldssortFields
- of type FieldsreverseOrder
- of type booleanprotected Splice(String spliceName, Pipe pipe, Fields groupFields, Fields sortFields, boolean reverseOrder)
spliceName
- of type Stringpipe
- of type PipegroupFields
- of type FieldssortFields
- of type FieldsreverseOrder
- of type booleanprotected Splice(Pipe[] pipes, Fields groupFields)
pipes
- of type PipegroupFields
- of type Fieldsprotected Splice(String spliceName, Pipe[] pipes, Fields groupFields)
spliceName
- of type Stringpipes
- of type PipegroupFields
- of type Fieldsprotected Splice(Pipe[] pipes, Fields groupFields, Fields sortFields)
pipes
- of type PipegroupFields
- of type FieldssortFields
- of type Fieldsprotected Splice(String spliceName, Pipe[] pipe, Fields groupFields, Fields sortFields)
spliceName
- of type Stringpipe
- of type PipegroupFields
- of type FieldssortFields
- of type Fieldsprotected Splice(Pipe[] pipes, Fields groupFields, Fields sortFields, boolean reverseOrder)
pipes
- of type PipegroupFields
- of type FieldssortFields
- of type FieldsreverseOrder
- of type booleanprotected Splice(String spliceName, Pipe[] pipes, Fields groupFields, Fields sortFields, boolean reverseOrder)
spliceName
- of type Stringpipes
- of type Pipe[]groupFields
- of type FieldssortFields
- of type FieldsreverseOrder
- of type booleanpublic Fields getDeclaredFields()
public String getName()
Pipe
public Pipe[] getPrevious()
Pipe
getPrevious
in class Pipe
public Map<String,Fields> getKeySelectors()
public Map<String,Fields> getSortingSelectors()
public boolean isSorted()
public boolean isSortReversed()
public Map<String,Integer> getPipePos()
public final boolean isGroupBy()
public final boolean isCoGroup()
public final boolean isMerge()
public final boolean isJoin()
public int getNumSelfJoins()
public boolean isSelfJoin()
public Scope outgoingScopeFor(Set<Scope> incomingScopes)
FlowElement
outgoingScopeFor
in interface FlowElement
outgoingScopeFor
in class Pipe
incomingScopes
- of type Setpublic Fields resolveIncomingOperationPassThroughFields(Scope incomingScope)
FlowElement
resolveIncomingOperationPassThroughFields
in interface FlowElement
resolveIncomingOperationPassThroughFields
in class Pipe
incomingScope
- of type Scopepublic Fields getJoinDeclaredFields()
public boolean isEquivalentTo(FlowElement element)
isEquivalentTo
in interface FlowElement
isEquivalentTo
in class Pipe
protected void printInternal(StringBuffer buffer, Scope scope)
printInternal
in class Pipe
Copyright © 2007-2015 Concurrent, Inc. All Rights Reserved.