Pivot<TInput>

Class Pivot<TInput>

Inherited Members
Namespace: ETLBox.DataFlow
Assembly: ETLBox.dll
Syntax
    public class Pivot<TInput> : DataFlowTransformation<TInput, ExpandoObject>, IDataFlowTransformation<TInput, ExpandoObject>, IDataFlowSource<ExpandoObject>, IDataFlowSource, IDataFlowDestination<TInput>, IDataFlowDestination, IDataFlowComponent, ILoggableTask
Type Parameters
NameDescription
TInput

Constructors

Pivot()

Declaration
    public Pivot()

Fields

ColumnNameGenerationFunc

Declaration
    public Func<Dictionary<string, object>, string> ColumnNameGenerationFunc
Field Value
TypeDescription
Func<Dictionary<string, object>, string>

ValueAggregationFunc

Declaration
    public Func<Dictionary<string, object>, object> ValueAggregationFunc
Field Value
TypeDescription
Func<Dictionary<string, object>, object>

Properties

KeepEmptyValues

Declaration
    public bool KeepEmptyValues { get; set; }
Property Value
TypeDescription
bool

MaxBufferSize

Declaration
    public int MaxBufferSize { get; }
Property Value
TypeDescription
int

PivotColumns

Declaration
    public ICollection<PivotColumn> PivotColumns { get; set; }
Property Value
TypeDescription
ICollection<PivotColumn>

PivotValueColumns

Declaration
    public ICollection<PivotValueColumn> PivotValueColumns { get; set; }
Property Value
TypeDescription
ICollection<PivotValueColumn>

ProgressCount

Declaration
    public int ProgressCount { get; }
Property Value
TypeDescription
int

SourceBlock

SourceBlock from the underlying TPL.Dataflow which is used as output buffer for the component.

Declaration
    public override ISourceBlock<ExpandoObject> SourceBlock { get; }
Property Value
TypeDescription
ISourceBlock<ExpandoObject>
Overrides

TargetBlock

TargetBlock from the underlying TPL.Dataflow which is used as input buffer for the component.

Declaration
    public override ITargetBlock<TInput> TargetBlock { get; }
Property Value
TypeDescription
ITargetBlock<TInput>
Overrides

Methods

CheckParameter()

Declaration
    protected override void CheckParameter()
Overrides

CleanUpOnFaulted(Exception)

Declaration
    protected override void CleanUpOnFaulted(Exception e)
Parameters
TypeNameDescription
Exceptione
Overrides

CleanUpOnSuccess()

Declaration
    protected override void CleanUpOnSuccess()
Overrides

InitComponent()

Declaration
    protected override void InitComponent()
Overrides

LinkErrorTo(IDataFlowDestination<ETLBoxError>)

If an error occurs in the component, by default the component will throw an exception and stop execution. If you use the error linking, any erroneous records will be caught and redirected.

Declaration
    public override IDataFlowSource<ETLBoxError> LinkErrorTo(IDataFlowDestination<ETLBoxError> target)
Parameters
TypeNameDescription
IDataFlowDestination<ETLBoxError>target

The target for erroneous rows.

Returns
TypeDescription
IDataFlowSource<ETLBoxError>

The linked component.

Overrides

PrepareParameterForCheck()

Declaration
    protected override void PrepareParameterForCheck()
Overrides

Reset()

Declaration
    protected override void Reset()
Overrides

Implements