|
||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |
java.lang.Object cascading.pipe.Pipe cascading.pipe.Group cascading.pipe.CoGroup jp.hishidama.hadoop.cascading.pipe.CoGroupEx
public class CoGroupEx
拡張CoGroup.
当クラスでは、出力項目名(declaredFields)を指定しなかった場合に、自動的に定義する。
その際、重複した項目名があった場合は別の名前を付ける。
CoGroupExのコンストラクターは、CoGroupのコンストラクターのコピペ。
→使用例
コンストラクタの概要 | |
---|---|
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 |
コンストラクタの詳細 |
---|
@ConstructorProperties(value={"lhs","lhsGroupFields","rhs","rhsGroupFields","declaredFields"}) public CoGroupEx(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 Fields@ConstructorProperties(value={"lhs","lhsGroupFields","rhs","rhsGroupFields","declaredFields","resultGroupFields"}) public CoGroupEx(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 Fields@ConstructorProperties(value={"lhs","lhsGroupFields","rhs","rhsGroupFields","declaredFields","joiner"}) public CoGroupEx(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 CoGrouper@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)
lhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type FieldsresultGroupFields
- of type Fieldsjoiner
- of type Joiner@ConstructorProperties(value={"lhs","lhsGroupFields","rhs","rhsGroupFields","joiner"}) public CoGroupEx(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 CoGrouper@ConstructorProperties(value={"lhs","lhsGroupFields","rhs","rhsGroupFields"}) public CoGroupEx(Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields)
lhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type Fields@ConstructorProperties(value="pipes") public CoGroupEx(Pipe... pipes)
pipes
- of type Pipe...@ConstructorProperties(value={"pipes","groupFields"}) public CoGroupEx(Pipe[] pipes, Fields[] groupFields)
pipes
- of type Pipe[]groupFields
- of type Fields[]@ConstructorProperties(value={"pipes","groupFields","declaredFields","joiner"}) public CoGroupEx(Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Joiner joiner)
pipes
- of type Pipe[]groupFields
- of type Fields[]declaredFields
- of type Fieldsjoiner
- of type CoGrouper@ConstructorProperties(value={"pipes","groupFields","declaredFields","resultGroupFields","joiner"}) public CoGroupEx(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 Joiner@ConstructorProperties(value={"groupName","pipes","groupFields"}) public CoGroupEx(String groupName, Pipe[] pipes, Fields[] groupFields)
groupName
- of type Stringpipes
- of type Pipe[]groupFields
- of type Fields[]@ConstructorProperties(value={"groupName","pipes","groupFields","declaredFields"}) public CoGroupEx(String groupName, Pipe[] pipes, Fields[] groupFields, Fields declaredFields)
groupName
- of type Stringpipes
- of type Pipe[]groupFields
- of type Fields[]declaredFields
- of type Fields@ConstructorProperties(value={"groupName","pipes","groupFields","declaredFields","resultGroupFields"}) public CoGroupEx(String groupName, Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Fields resultGroupFields)
groupName
- of type Stringpipes
- of type Pipe[]groupFields
- of type Fields[]declaredFields
- of type FieldsresultGroupFields
- of type Fields@ConstructorProperties(value={"groupName","pipes","groupFields","declaredFields","joiner"}) public CoGroupEx(String groupName, Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Joiner joiner)
groupName
- of type Stringpipes
- of type Pipe[]groupFields
- of type Fields[]declaredFields
- of type Fieldsjoiner
- of type CoGrouper@ConstructorProperties(value={"groupName","pipes","groupFields","declaredFields","resultGroupFields","joiner"}) public CoGroupEx(String groupName, Pipe[] pipes, Fields[] groupFields, Fields declaredFields, Fields resultGroupFields, Joiner joiner)
groupName
- of type Stringpipes
- of type Pipe[]groupFields
- of type Fields[]declaredFields
- of type FieldsresultGroupFields
- of type Fieldsjoiner
- of type CoGrouper@ConstructorProperties(value={"groupName","lhs","lhsGroupFields","rhs","rhsGroupFields","declaredFields"}) public CoGroupEx(String groupName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Fields declaredFields)
groupName
- of type Stringlhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type Fields@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)
groupName
- of type Stringlhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type FieldsresultGroupFields
- of type Fields@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)
groupName
- of type Stringlhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type Fieldsjoiner
- of type CoGrouper@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)
groupName
- of type Stringlhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type FieldsdeclaredFields
- of type FieldsresultGroupFields
- of type Fieldsjoiner
- of type Joiner@ConstructorProperties(value={"groupName","lhs","lhsGroupFields","rhs","rhsGroupFields","joiner"}) public CoGroupEx(String groupName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields, Joiner joiner)
groupName
- of type Stringlhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type Fieldsjoiner
- of type CoGrouper@ConstructorProperties(value={"groupName","lhs","lhsGroupFields","rhs","rhsGroupFields"}) public CoGroupEx(String groupName, Pipe lhs, Fields lhsGroupFields, Pipe rhs, Fields rhsGroupFields)
groupName
- of type Stringlhs
- of type PipelhsGroupFields
- of type Fieldsrhs
- of type PiperhsGroupFields
- of type Fields@ConstructorProperties(value={"groupName","pipes"}) public CoGroupEx(String groupName, Pipe... pipes)
groupName
- of type Stringpipes
- of type Pipe...@ConstructorProperties(value={"pipe","groupFields","numSelfJoins","declaredFields"}) public CoGroupEx(Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields)
Pipe
instance.
pipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type Fields@ConstructorProperties(value={"pipe","groupFields","numSelfJoins","declaredFields","resultGroupFields"}) public CoGroupEx(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 Fields@ConstructorProperties(value={"pipe","groupFields","numSelfJoins","declaredFields","joiner"}) public CoGroupEx(Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Joiner joiner)
Pipe
instance.
pipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type Fieldsjoiner
- of type CoGrouper@ConstructorProperties(value={"pipe","groupFields","numSelfJoins","declaredFields","resultGroupFields","joiner"}) public CoGroupEx(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 Joiner@ConstructorProperties(value={"pipe","groupFields","numSelfJoins","joiner"}) public CoGroupEx(Pipe pipe, Fields groupFields, int numSelfJoins, Joiner joiner)
Pipe
instance.
pipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intjoiner
- of type CoGrouper@ConstructorProperties(value={"pipe","groupFields","numSelfJoins"}) public CoGroupEx(Pipe pipe, Fields groupFields, int numSelfJoins)
Pipe
instance.
pipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type int@ConstructorProperties(value={"groupName","pipe","groupFields","numSelfJoins","declaredFields"}) public CoGroupEx(String groupName, Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields)
Pipe
instance.
groupName
- of type Stringpipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type Fields@ConstructorProperties(value={"groupName","pipe","groupFields","numSelfJoins","declaredFields","resultGroupFields"}) public CoGroupEx(String groupName, Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Fields resultGroupFields)
groupName
- of type Stringpipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type FieldsresultGroupFields
- of type Fields@ConstructorProperties(value={"groupName","pipe","groupFields","numSelfJoins","declaredFields","joiner"}) public CoGroupEx(String groupName, Pipe pipe, Fields groupFields, int numSelfJoins, Fields declaredFields, Joiner joiner)
Pipe
instance.
groupName
- of type Stringpipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type Fieldsjoiner
- of type CoGrouper@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)
groupName
- of type Stringpipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intdeclaredFields
- of type FieldsresultGroupFields
- of type Fieldsjoiner
- of type Joiner@ConstructorProperties(value={"groupName","pipe","groupFields","numSelfJoins","joiner"}) public CoGroupEx(String groupName, Pipe pipe, Fields groupFields, int numSelfJoins, Joiner joiner)
Pipe
instance.
groupName
- of type Stringpipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intjoiner
- of type CoGrouper@ConstructorProperties(value={"groupName","pipe","groupFields","numSelfJoins"}) public CoGroupEx(String groupName, Pipe pipe, Fields groupFields, int numSelfJoins)
Pipe
instance.
groupName
- of type Stringpipe
- of type PipegroupFields
- of type FieldsnumSelfJoins
- of type intメソッドの詳細 |
---|
public Scope outgoingScopeFor(Set<Scope> incomingScopes)
FlowElement
内の outgoingScopeFor
Group
内の outgoingScopeFor
|
||||||||
前のクラス 次のクラス | フレームあり フレームなし | |||||||
概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド |