jp.hishidama.hadoop.cascading.pipe
クラス CoGroupEx

java.lang.Object
  上位を拡張 cascading.pipe.Pipe
      上位を拡張 cascading.pipe.Group
          上位を拡張 cascading.pipe.CoGroup
              上位を拡張 jp.hishidama.hadoop.cascading.pipe.CoGroupEx
すべての実装されたインタフェース:
FlowElement, Serializable

public class CoGroupEx
extends CoGroup

拡張CoGroup.

当クラスでは、出力項目名(declaredFields)を指定しなかった場合に、自動的に定義する。
その際、重複した項目名があった場合は別の名前を付ける。

CoGroupExのコンストラクターは、CoGroupのコンストラクターのコピペ。

使用例

導入されたバージョン:
2010.04.13
バージョン:
2010.05.01 Cascading1.1
作成者:
ひしだま
関連項目:
直列化された形式

コンストラクタの概要
CoGroupEx(Pipe... pipes)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(Pipe[] pipes, Fields[] groupFields)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(Pipe pipe, Fields groupFields, int numSelfJoins)
          Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroupEx(Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields)
          Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroupEx(Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Fields resultGroupFields)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroupEx(Pipe pipe, Fields groupFields, int numSelfJoins, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroupEx(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields, Fields resultGroupFields)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe... pipes)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe[] pipes, Fields[] groupFields)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe[] pipes, Fields[] groupFields, Fields declaredFields)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Fields resultGroupFields)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe pipe, Fields groupFields, int numSelfJoins)
          Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroupEx(String groupName, Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields)
          Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroupEx(String groupName, Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Fields resultGroupFields)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroupEx(String groupName, Pipe pipe, Fields groupFields, int numSelfJoins, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.
CoGroupEx(String groupName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields, Fields resultGroupFields)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance.
CoGroupEx(String groupName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Joiner joiner)
          Constructor CoGroup creates a new CoGroup instance.
 
メソッドの概要
 Scope outgoingScopeFor(Set<Scope> incomingScopes)
          出力項目名(declaredFields)がnullの場合に項目名を定義してから、スーパークラスのメソッドを呼び出す。
 
クラス cascading.pipe.Group から継承されたメソッド
collectReduceGrouping, equals, getDeclaredFields, getGroupingSelectors, getName, getPrevious, getSortingSelectors, hashCode, isGroupBy, isSorted, isSortReversed, iterateReduceValues, resolveFields, toString, unwrapGrouping
 
クラス cascading.pipe.Pipe から継承されたメソッド
getHeads, getTrace, pipes, print, resolveIncomingOperationFields
 
クラス java.lang.Object から継承されたメソッド
getClass, notify, notifyAll, wait, wait, wait
 

コンストラクタの詳細

CoGroupEx

@ConstructorProperties(value={"lhs","lhsGroupFields","rhs","rhsGroupFields","declaredFields"})
public CoGroupEx(Pipe lhs,
                                            Fields lhsGroupFields,
                                            Pipe rhs,
                                            Fields rhsGroupFields,
                                            Fields declaredFields)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
lhs - of type Pipe
lhsGroupFields - of type Fields
rhs - of type Pipe
rhsGroupFields - of type Fields
declaredFields - of type Fields

CoGroupEx

@ConstructorProperties(value={"lhs","lhsGroupFields","rhs","rhsGroupFields","declaredFields","resultGroupFields"})
public CoGroupEx(Pipe lhs,
                                            Fields lhsGroupFields,
                                            Pipe rhs,
                                            Fields rhsGroupFields,
                                            Fields declaredFields,
                                            Fields resultGroupFields)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
lhs - of type Pipe
lhsGroupFields - of type Fields
rhs - of type Pipe
rhsGroupFields - of type Fields
declaredFields - of type Fields
resultGroupFields - of type Fields

CoGroupEx

@ConstructorProperties(value={"lhs","lhsGroupFields","rhs","rhsGroupFields","declaredFields","joiner"})
public CoGroupEx(Pipe lhs,
                                            Fields lhsGroupFields,
                                            Pipe rhs,
                                            Fields rhsGroupFields,
                                            Fields declaredFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
lhs - of type Pipe
lhsGroupFields - of type Fields
rhs - of type Pipe
rhsGroupFields - of type Fields
declaredFields - of type Fields
joiner - of type CoGrouper

CoGroupEx

@ConstructorProperties(value={"lhs","lhsGroupFields","rhs","rhsGroupFields","declaredFields","resultGroupFields","joiner"})
public CoGroupEx(Pipe lhs,
                                            Fields lhsGroupFields,
                                            Pipe rhs,
                                            Fields rhsGroupFields,
                                            Fields declaredFields,
                                            Fields resultGroupFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
lhs - of type Pipe
lhsGroupFields - of type Fields
rhs - of type Pipe
rhsGroupFields - of type Fields
declaredFields - of type Fields
resultGroupFields - of type Fields
joiner - of type Joiner

CoGroupEx

@ConstructorProperties(value={"lhs","lhsGroupFields","rhs","rhsGroupFields","joiner"})
public CoGroupEx(Pipe lhs,
                                            Fields lhsGroupFields,
                                            Pipe rhs,
                                            Fields rhsGroupFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
lhs - of type Pipe
lhsGroupFields - of type Fields
rhs - of type Pipe
rhsGroupFields - of type Fields
joiner - of type CoGrouper

CoGroupEx

@ConstructorProperties(value={"lhs","lhsGroupFields","rhs","rhsGroupFields"})
public CoGroupEx(Pipe lhs,
                                            Fields lhsGroupFields,
                                            Pipe rhs,
                                            Fields rhsGroupFields)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
lhs - of type Pipe
lhsGroupFields - of type Fields
rhs - of type Pipe
rhsGroupFields - of type Fields

CoGroupEx

@ConstructorProperties(value="pipes")
public CoGroupEx(Pipe... pipes)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
pipes - of type Pipe...

CoGroupEx

@ConstructorProperties(value={"pipes","groupFields"})
public CoGroupEx(Pipe[] pipes,
                                            Fields[] groupFields)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
pipes - of type Pipe[]
groupFields - of type Fields[]

CoGroupEx

@ConstructorProperties(value={"pipes","groupFields","declaredFields","joiner"})
public CoGroupEx(Pipe[] pipes,
                                            Fields[] groupFields,
                                            Fields declaredFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
pipes - of type Pipe[]
groupFields - of type Fields[]
declaredFields - of type Fields
joiner - of type CoGrouper

CoGroupEx

@ConstructorProperties(value={"pipes","groupFields","declaredFields","resultGroupFields","joiner"})
public CoGroupEx(Pipe[] pipes,
                                            Fields[] groupFields,
                                            Fields declaredFields,
                                            Fields resultGroupFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
pipes - of type Pipe[]
groupFields - of type Fields[]
declaredFields - of type Fields
resultGroupFields - of type Fields
joiner - of type Joiner

CoGroupEx

@ConstructorProperties(value={"groupName","pipes","groupFields"})
public CoGroupEx(String groupName,
                                            Pipe[] pipes,
                                            Fields[] groupFields)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
pipes - of type Pipe[]
groupFields - of type Fields[]

CoGroupEx

@ConstructorProperties(value={"groupName","pipes","groupFields","declaredFields"})
public CoGroupEx(String groupName,
                                            Pipe[] pipes,
                                            Fields[] groupFields,
                                            Fields declaredFields)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
pipes - of type Pipe[]
groupFields - of type Fields[]
declaredFields - of type Fields

CoGroupEx

@ConstructorProperties(value={"groupName","pipes","groupFields","declaredFields","resultGroupFields"})
public CoGroupEx(String groupName,
                                            Pipe[] pipes,
                                            Fields[] groupFields,
                                            Fields declaredFields,
                                            Fields resultGroupFields)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
pipes - of type Pipe[]
groupFields - of type Fields[]
declaredFields - of type Fields
resultGroupFields - of type Fields

CoGroupEx

@ConstructorProperties(value={"groupName","pipes","groupFields","declaredFields","joiner"})
public CoGroupEx(String groupName,
                                            Pipe[] pipes,
                                            Fields[] groupFields,
                                            Fields declaredFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
pipes - of type Pipe[]
groupFields - of type Fields[]
declaredFields - of type Fields
joiner - of type CoGrouper

CoGroupEx

@ConstructorProperties(value={"groupName","pipes","groupFields","declaredFields","resultGroupFields","joiner"})
public CoGroupEx(String groupName,
                                            Pipe[] pipes,
                                            Fields[] groupFields,
                                            Fields declaredFields,
                                            Fields resultGroupFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
pipes - of type Pipe[]
groupFields - of type Fields[]
declaredFields - of type Fields
resultGroupFields - of type Fields
joiner - of type CoGrouper

CoGroupEx

@ConstructorProperties(value={"groupName","lhs","lhsGroupFields","rhs","rhsGroupFields","declaredFields"})
public CoGroupEx(String groupName,
                                            Pipe lhs,
                                            Fields lhsGroupFields,
                                            Pipe rhs,
                                            Fields rhsGroupFields,
                                            Fields declaredFields)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
lhs - of type Pipe
lhsGroupFields - of type Fields
rhs - of type Pipe
rhsGroupFields - of type Fields
declaredFields - of type Fields

CoGroupEx

@ConstructorProperties(value={"groupName","lhs","lhsGroupFields","rhs","rhsGroupFields","declaredFields","resultGroupFields"})
public CoGroupEx(String groupName,
                                            Pipe lhs,
                                            Fields lhsGroupFields,
                                            Pipe rhs,
                                            Fields rhsGroupFields,
                                            Fields declaredFields,
                                            Fields resultGroupFields)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
lhs - of type Pipe
lhsGroupFields - of type Fields
rhs - of type Pipe
rhsGroupFields - of type Fields
declaredFields - of type Fields
resultGroupFields - of type Fields

CoGroupEx

@ConstructorProperties(value={"groupName","lhs","lhsGroupFields","rhs","rhsGroupFields","declaredFields","joiner"})
public CoGroupEx(String groupName,
                                            Pipe lhs,
                                            Fields lhsGroupFields,
                                            Pipe rhs,
                                            Fields rhsGroupFields,
                                            Fields declaredFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
lhs - of type Pipe
lhsGroupFields - of type Fields
rhs - of type Pipe
rhsGroupFields - of type Fields
declaredFields - of type Fields
joiner - of type CoGrouper

CoGroupEx

@ConstructorProperties(value={"groupName","lhs","lhsGroupFields","rhs","rhsGroupFields","declaredFields","resultGroupFields","joiner"})
public CoGroupEx(String groupName,
                                            Pipe lhs,
                                            Fields lhsGroupFields,
                                            Pipe rhs,
                                            Fields rhsGroupFields,
                                            Fields declaredFields,
                                            Fields resultGroupFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
lhs - of type Pipe
lhsGroupFields - of type Fields
rhs - of type Pipe
rhsGroupFields - of type Fields
declaredFields - of type Fields
resultGroupFields - of type Fields
joiner - of type Joiner

CoGroupEx

@ConstructorProperties(value={"groupName","lhs","lhsGroupFields","rhs","rhsGroupFields","joiner"})
public CoGroupEx(String groupName,
                                            Pipe lhs,
                                            Fields lhsGroupFields,
                                            Pipe rhs,
                                            Fields rhsGroupFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
lhs - of type Pipe
lhsGroupFields - of type Fields
rhs - of type Pipe
rhsGroupFields - of type Fields
joiner - of type CoGrouper

CoGroupEx

@ConstructorProperties(value={"groupName","lhs","lhsGroupFields","rhs","rhsGroupFields"})
public CoGroupEx(String groupName,
                                            Pipe lhs,
                                            Fields lhsGroupFields,
                                            Pipe rhs,
                                            Fields rhsGroupFields)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
lhs - of type Pipe
lhsGroupFields - of type Fields
rhs - of type Pipe
rhsGroupFields - of type Fields

CoGroupEx

@ConstructorProperties(value={"groupName","pipes"})
public CoGroupEx(String groupName,
                                            Pipe... pipes)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
pipes - of type Pipe...

CoGroupEx

@ConstructorProperties(value={"pipe","groupFields","numSelfJoins","declaredFields"})
public CoGroupEx(Pipe pipe,
                                            Fields groupFields,
                                            int numSelfJoins,
                                            Fields declaredFields)
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.

パラメータ:
pipe - of type Pipe
groupFields - of type Fields
numSelfJoins - of type int
declaredFields - of type Fields

CoGroupEx

@ConstructorProperties(value={"pipe","groupFields","numSelfJoins","declaredFields","resultGroupFields"})
public CoGroupEx(Pipe pipe,
                                            Fields groupFields,
                                            int numSelfJoins,
                                            Fields declaredFields,
                                            Fields resultGroupFields)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
pipe - of type Pipe
groupFields - of type Fields
numSelfJoins - of type int
declaredFields - of type Fields
resultGroupFields - of type Fields

CoGroupEx

@ConstructorProperties(value={"pipe","groupFields","numSelfJoins","declaredFields","joiner"})
public CoGroupEx(Pipe pipe,
                                            Fields groupFields,
                                            int numSelfJoins,
                                            Fields declaredFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.

パラメータ:
pipe - of type Pipe
groupFields - of type Fields
numSelfJoins - of type int
declaredFields - of type Fields
joiner - of type CoGrouper

CoGroupEx

@ConstructorProperties(value={"pipe","groupFields","numSelfJoins","declaredFields","resultGroupFields","joiner"})
public CoGroupEx(Pipe pipe,
                                            Fields groupFields,
                                            int numSelfJoins,
                                            Fields declaredFields,
                                            Fields resultGroupFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
pipe - of type Pipe
groupFields - of type Fields
numSelfJoins - of type int
declaredFields - of type Fields
resultGroupFields - of type Fields
joiner - of type Joiner

CoGroupEx

@ConstructorProperties(value={"pipe","groupFields","numSelfJoins","joiner"})
public CoGroupEx(Pipe pipe,
                                            Fields groupFields,
                                            int numSelfJoins,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.

パラメータ:
pipe - of type Pipe
groupFields - of type Fields
numSelfJoins - of type int
joiner - of type CoGrouper

CoGroupEx

@ConstructorProperties(value={"pipe","groupFields","numSelfJoins"})
public CoGroupEx(Pipe pipe,
                                            Fields groupFields,
                                            int numSelfJoins)
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.

パラメータ:
pipe - of type Pipe
groupFields - of type Fields
numSelfJoins - of type int

CoGroupEx

@ConstructorProperties(value={"groupName","pipe","groupFields","numSelfJoins","declaredFields"})
public CoGroupEx(String groupName,
                                            Pipe pipe,
                                            Fields groupFields,
                                            int numSelfJoins,
                                            Fields declaredFields)
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.

パラメータ:
groupName - of type String
pipe - of type Pipe
groupFields - of type Fields
numSelfJoins - of type int
declaredFields - of type Fields

CoGroupEx

@ConstructorProperties(value={"groupName","pipe","groupFields","numSelfJoins","declaredFields","resultGroupFields"})
public CoGroupEx(String groupName,
                                            Pipe pipe,
                                            Fields groupFields,
                                            int numSelfJoins,
                                            Fields declaredFields,
                                            Fields resultGroupFields)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
pipe - of type Pipe
groupFields - of type Fields
numSelfJoins - of type int
declaredFields - of type Fields
resultGroupFields - of type Fields

CoGroupEx

@ConstructorProperties(value={"groupName","pipe","groupFields","numSelfJoins","declaredFields","joiner"})
public CoGroupEx(String groupName,
                                            Pipe pipe,
                                            Fields groupFields,
                                            int numSelfJoins,
                                            Fields declaredFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.

パラメータ:
groupName - of type String
pipe - of type Pipe
groupFields - of type Fields
numSelfJoins - of type int
declaredFields - of type Fields
joiner - of type CoGrouper

CoGroupEx

@ConstructorProperties(value={"groupName","pipe","groupFields","numSelfJoins","declaredFields","resultGroupFields","joiner"})
public CoGroupEx(String groupName,
                                            Pipe pipe,
                                            Fields groupFields,
                                            int numSelfJoins,
                                            Fields declaredFields,
                                            Fields resultGroupFields,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance.

パラメータ:
groupName - of type String
pipe - of type Pipe
groupFields - of type Fields
numSelfJoins - of type int
declaredFields - of type Fields
resultGroupFields - of type Fields
joiner - of type Joiner

CoGroupEx

@ConstructorProperties(value={"groupName","pipe","groupFields","numSelfJoins","joiner"})
public CoGroupEx(String groupName,
                                            Pipe pipe,
                                            Fields groupFields,
                                            int numSelfJoins,
                                            Joiner joiner)
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.

パラメータ:
groupName - of type String
pipe - of type Pipe
groupFields - of type Fields
numSelfJoins - of type int
joiner - of type CoGrouper

CoGroupEx

@ConstructorProperties(value={"groupName","pipe","groupFields","numSelfJoins"})
public CoGroupEx(String groupName,
                                            Pipe pipe,
                                            Fields groupFields,
                                            int numSelfJoins)
Constructor CoGroup creates a new CoGroup instance that performs numSelfJoins number of self joins on the given Pipe instance.

パラメータ:
groupName - of type String
pipe - of type Pipe
groupFields - of type Fields
numSelfJoins - of type int
メソッドの詳細

outgoingScopeFor

public Scope outgoingScopeFor(Set<Scope> incomingScopes)
出力項目名(declaredFields)がnullの場合に項目名を定義してから、スーパークラスのメソッドを呼び出す。

定義:
インタフェース FlowElement 内の outgoingScopeFor
オーバーライド:
クラス Group 内の outgoingScopeFor