|
||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||
java.lang.Objectcascading.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 内の outgoingScopeForGroup 内の outgoingScopeFor
|
||||||||
| 前のクラス 次のクラス | フレームあり フレームなし | |||||||
| 概要: 入れ子 | フィールド | コンストラクタ | メソッド | 詳細: フィールド | コンストラクタ | メソッド | |||||||