For the reader implementation see the example in CustomDataRowReader
[Serializable] 
public class EveryNColumnsTransformation : CustomDataTransformation
{
    private int n;

    public EveryNColumnsTransformation()
    {
        n = 2;
    }

    public int N
    {
        get { return n; }
        set { n = value; }
    }

    protected override DataTransformationConnection ConnectCore(ImportContext importContext, DataRowReader input)
    {
        PromptService promptService = importContext.PromptService;
        List<object> promptModels = new List<object>();
        if (promptService.IsPromptingAllowed)
        {
            promptModels.Add(this);
        }

        //prompt for a value of N that the dialog sets directly on the promptmodel 

        return
            DataTransformationConnection.CreateConnection(
            delegate { return new EveryNColumnsTransformationReader(input, N); },
            promptModels);
    }

    public EveryNColumnsTransformation(SerializationInfo info, StreamingContext context)
        : base(info, context)
    {
        n = info.GetInt32("n");
    }

    protected override void GetObjectData(SerializationInfo info, StreamingContext context)
    {
        base.GetObjectData(info, context);
        info.AddValue("n", n);
    }   
}

For the reader implementation see the example in CustomDataRowReader
[Serializable] 
public class EveryNColumnsTransformation : CustomDataTransformation
{
    private int n;

    public EveryNColumnsTransformation()
    {
        n = 2;
    }

    public int N
    {
        get { return n; }
        set { n = value; }
    }

    protected override DataTransformationConnection ConnectCore(ImportContext importContext, DataRowReader input)
    {
        PromptService promptService = importContext.PromptService;
        List<object> promptModels = new List<object>();
        if (promptService.IsPromptingAllowed)
        {
            promptModels.Add(this);
        }

        //prompt for a value of N that the dialog sets directly on the promptmodel 

        return
            DataTransformationConnection.CreateConnection(
            delegate { return new EveryNColumnsTransformationReader(input, N); },
            promptModels);
    }

    public EveryNColumnsTransformation(SerializationInfo info, StreamingContext context)
        : base(info, context)
    {
        n = info.GetInt32("n");
    }

    protected override void GetObjectData(SerializationInfo info, StreamingContext context)
    {
        base.GetObjectData(info, context);
        info.AddValue("n", n);
    }   
}