diff --git a/src/Microsoft.ML.Data/StaticPipe/PipelineColumn.cs b/src/Microsoft.ML.Data/StaticPipe/PipelineColumn.cs
index bf097b9571..91e68c4c30 100644
--- a/src/Microsoft.ML.Data/StaticPipe/PipelineColumn.cs
+++ b/src/Microsoft.ML.Data/StaticPipe/PipelineColumn.cs
@@ -34,7 +34,7 @@ private protected PipelineColumn(Reconciler reconciler, PipelineColumn[] depende
     /// <summary>
     /// For representing a non-key, non-vector <see cref="ColumnType"/>.
     /// </summary>
-    /// <typeparam name="T"></typeparam>
+    /// <typeparam name="T">The scalar item type.</typeparam>
     public abstract class Scalar<T> : PipelineColumn
     {
         protected Scalar(Reconciler reconciler, params PipelineColumn[] dependencies)
@@ -142,4 +142,19 @@ protected VarKey(Reconciler reconciler, params PipelineColumn[] dependencies)
 
         public override string ToString() => $"{nameof(VarKey<T>)}<{typeof(T).Name}>";
     }
+
+    /// <summary>
+    /// For representing a custom <see cref="ColumnType"/>.
+    /// </summary>
+    /// <typeparam name="T">The custom item type.</typeparam>
+    public abstract class Custom<T>: PipelineColumn
+    {
+        protected Custom(Reconciler reconciler, params PipelineColumn[] dependencies)
+            : base(reconciler, dependencies)
+        {
+        }
+
+        public override string ToString() => $"{nameof(Custom<T>)}<{typeof(T).Name}>";
+    }
+
 }
diff --git a/src/Microsoft.ML.Data/StaticPipe/StaticPipeInternalUtils.cs b/src/Microsoft.ML.Data/StaticPipe/StaticPipeInternalUtils.cs
index 9b0040f3b3..4b61e90957 100644
--- a/src/Microsoft.ML.Data/StaticPipe/StaticPipeInternalUtils.cs
+++ b/src/Microsoft.ML.Data/StaticPipe/StaticPipeInternalUtils.cs
@@ -59,6 +59,7 @@ private sealed class AVarVector<T> : VarVector<T> { public AVarVector(Rec rec) :
             private sealed class AKey<T> : Key<T> { public AKey(Rec rec) : base(rec, null) { } }
             private sealed class AKey<T, TV> : Key<T, TV> { public AKey(Rec rec) : base(rec, null) { } }
             private sealed class AVarKey<T> : VarKey<T> { public AVarKey(Rec rec) : base(rec, null) { } }
+            private sealed class ACustom<T> : Custom<T> { public ACustom(Rec rec) : base(rec, null) { } }
 
             private static PipelineColumn MakeScalar<T>(Rec rec) => new AScalar<T>(rec);
             private static PipelineColumn MakeVector<T>(Rec rec) => new AVector<T>(rec);
@@ -67,6 +68,7 @@ private sealed class AVarKey<T> : VarKey<T> { public AVarKey(Rec rec) : base(rec
             private static PipelineColumn MakeKey<T>(Rec rec) => new AKey<T>(rec);
             private static Key<T, TV> MakeKey<T, TV>(Rec rec) => new AKey<T, TV>(rec);
             private static PipelineColumn MakeVarKey<T>(Rec rec) => new AVarKey<T>(rec);
+            private static PipelineColumn MakeCustom<T>(Rec rec) => new ACustom<T>(rec);
 
             private static MethodInfo[] _valueTupleCreateMethod = InitValueTupleCreateMethods();
 
@@ -121,6 +123,8 @@ public static object MakeAnalysisInstanceCore<T>(Rec rec)
                         }
                         if (genT == typeof(VarKey<>))
                             return Utils.MarshalInvoke(MakeVector<int>, genP[0], rec);
+                        if (genT== typeof(Custom<>))
+                            return Utils.MarshalInvoke(MakeCustom<int>, genP[0], rec);
                     }
                     throw Contracts.Except($"Type {t} is a {nameof(PipelineColumn)} yet does not appear to be directly one of " +
                         $"the official types. This is commonly due to a mistake by the component author and can be addressed by " +
diff --git a/src/Microsoft.ML.Data/StaticPipe/StaticSchemaShape.cs b/src/Microsoft.ML.Data/StaticPipe/StaticSchemaShape.cs
index df981d25bb..82ae82141f 100644
--- a/src/Microsoft.ML.Data/StaticPipe/StaticSchemaShape.cs
+++ b/src/Microsoft.ML.Data/StaticPipe/StaticSchemaShape.cs
@@ -195,7 +195,7 @@ private static bool IsStandard(IExceptionContext ectx, Type t)
             }
             var gt = t.IsGenericType ? t.GetGenericTypeDefinition() : t;
             if (gt != typeof(Scalar<>) && gt != typeof(Key<>) && gt != typeof(Key<,>) && gt != typeof(VarKey<>) &&
-                gt != typeof(Vector<>) && gt != typeof(VarVector<>) && gt != typeof(NormVector<>))
+                gt != typeof(Vector<>) && gt != typeof(VarVector<>) && gt != typeof(NormVector<>) && gt != typeof(Custom<>))
             {
                 throw ectx.ExceptParam(nameof(t),
                     $"Type {t} was not one of the standard subclasses of {nameof(PipelineColumn)}");
diff --git a/src/Microsoft.ML.ImageAnalytics/ImageGrayscaleTransform.cs b/src/Microsoft.ML.ImageAnalytics/ImageGrayscaleTransform.cs
index f7dd526505..7a2fd6ba43 100644
--- a/src/Microsoft.ML.ImageAnalytics/ImageGrayscaleTransform.cs
+++ b/src/Microsoft.ML.ImageAnalytics/ImageGrayscaleTransform.cs
@@ -240,12 +240,12 @@ private interface IColInput
             PipelineColumn Input { get; }
         }
 
-        internal sealed class OutPipelineColumn<T> : Scalar<T>, IColInput
+        internal sealed class OutPipelineColumn<T> : Custom<T>, IColInput
         {
             public PipelineColumn Input { get; }
 
-            public OutPipelineColumn(Scalar<T> input)
-    : base(Reconciler.Inst, input)
+            public OutPipelineColumn(Custom<T> input)
+                : base(Reconciler.Inst, input)
             {
                 Contracts.AssertValue(input);
                 Contracts.Assert(typeof(T) == typeof(Bitmap) || typeof(T) == typeof(UnknownSizeBitmap));
@@ -257,8 +257,8 @@ public OutPipelineColumn(Scalar<T> input)
         /// Reconciler to an <see cref="ImageGrayscaleEstimator"/> for the <see cref="PipelineColumn"/>.
         /// </summary>
         /// <remarks>Because we want to use the same reconciler for </remarks>
-        /// <see cref="ImageStaticPipe.AsGrayscale(Scalar{Bitmap})"/>
-        /// <see cref="ImageStaticPipe.AsGrayscale(Scalar{UnknownSizeBitmap})"/>
+        /// <see cref="ImageStaticPipe.AsGrayscale(Custom{Bitmap})"/>
+        /// <see cref="ImageStaticPipe.AsGrayscale(Custom{UnknownSizeBitmap})"/>
         private sealed class Reconciler : EstimatorReconciler
         {
             public static Reconciler Inst = new Reconciler();
diff --git a/src/Microsoft.ML.ImageAnalytics/ImageLoaderTransform.cs b/src/Microsoft.ML.ImageAnalytics/ImageLoaderTransform.cs
index e0ad15bbd5..253bd523d2 100644
--- a/src/Microsoft.ML.ImageAnalytics/ImageLoaderTransform.cs
+++ b/src/Microsoft.ML.ImageAnalytics/ImageLoaderTransform.cs
@@ -242,7 +242,7 @@ public override SchemaShape GetOutputSchema(SchemaShape inputSchema)
             return new SchemaShape(result.Values);
         }
 
-        internal sealed class OutPipelineColumn : Scalar<UnknownSizeBitmap>
+        internal sealed class OutPipelineColumn : Custom<UnknownSizeBitmap>
         {
             private readonly Scalar<string> _input;
 
diff --git a/src/Microsoft.ML.ImageAnalytics/ImagePixelExtractorTransform.cs b/src/Microsoft.ML.ImageAnalytics/ImagePixelExtractorTransform.cs
index 0a70dee243..c526222501 100644
--- a/src/Microsoft.ML.ImageAnalytics/ImagePixelExtractorTransform.cs
+++ b/src/Microsoft.ML.ImageAnalytics/ImagePixelExtractorTransform.cs
@@ -669,18 +669,18 @@ public override SchemaShape GetOutputSchema(SchemaShape inputSchema)
 
         private interface IColInput
         {
-            Scalar<Bitmap> Input { get; }
+            Custom<Bitmap> Input { get; }
 
             ImagePixelExtractorTransform.ColumnInfo MakeColumnInfo(string input, string output);
         }
 
         internal sealed class OutPipelineColumn<T> : Vector<T>, IColInput
         {
-            public Scalar<Bitmap> Input { get; }
+            public Custom<Bitmap> Input { get; }
             private static readonly ImagePixelExtractorTransform.Arguments _defaultArgs = new ImagePixelExtractorTransform.Arguments();
             private readonly ImagePixelExtractorTransform.Column _colParam;
 
-            public OutPipelineColumn(Scalar<Bitmap> input, ImagePixelExtractorTransform.Column col)
+            public OutPipelineColumn(Custom<Bitmap> input, ImagePixelExtractorTransform.Column col)
                 : base(Reconciler.Inst, input)
             {
                 Contracts.AssertValue(input);
@@ -705,8 +705,8 @@ public ImagePixelExtractorTransform.ColumnInfo MakeColumnInfo(string input, stri
         /// Reconciler to an <see cref="ImagePixelExtractorEstimator"/> for the <see cref="PipelineColumn"/>.
         /// </summary>
         /// <remarks>Because we want to use the same reconciler for </remarks>
-        /// <see cref="ImageStaticPipe.ExtractPixels(Scalar{Bitmap}, bool, bool, bool, bool, bool, float, float)"/>
-        /// <see cref="ImageStaticPipe.ExtractPixelsAsBytes(Scalar{Bitmap}, bool, bool, bool, bool, bool)"/>
+        /// <see cref="ImageStaticPipe.ExtractPixels(Custom{Bitmap}, bool, bool, bool, bool, bool, float, float)"/>
+        /// <see cref="ImageStaticPipe.ExtractPixelsAsBytes(Custom{Bitmap}, bool, bool, bool, bool, bool)"/>
         private sealed class Reconciler : EstimatorReconciler
         {
             /// <summary>
diff --git a/src/Microsoft.ML.ImageAnalytics/ImageResizerTransform.cs b/src/Microsoft.ML.ImageAnalytics/ImageResizerTransform.cs
index 4db5d9ac01..83d5c97736 100644
--- a/src/Microsoft.ML.ImageAnalytics/ImageResizerTransform.cs
+++ b/src/Microsoft.ML.ImageAnalytics/ImageResizerTransform.cs
@@ -461,7 +461,7 @@ public override SchemaShape GetOutputSchema(SchemaShape inputSchema)
             return new SchemaShape(result.Values);
         }
 
-        internal sealed class OutPipelineColumn : Scalar<Bitmap>
+        internal sealed class OutPipelineColumn : Custom<Bitmap>
         {
             private readonly PipelineColumn _input;
             private readonly int _width;
@@ -487,8 +487,8 @@ private ImageResizerTransform.ColumnInfo MakeColumnInfo(string input, string out
             /// <summary>
             /// Reconciler to an <see cref="ImageResizerTransform"/> for the <see cref="PipelineColumn"/>.
             /// </summary>
-            /// <seealso cref="ImageStaticPipe.Resize(Scalar{Bitmap}, int, int, ImageResizerTransform.ResizingKind, ImageResizerTransform.Anchor)"/>
-            /// <seealso cref="ImageStaticPipe.Resize(Scalar{UnknownSizeBitmap}, int, int, ImageResizerTransform.ResizingKind, ImageResizerTransform.Anchor)"/>
+            /// <seealso cref="ImageStaticPipe.Resize(Custom{Bitmap}, int, int, ImageResizerTransform.ResizingKind, ImageResizerTransform.Anchor)"/>
+            /// <seealso cref="ImageStaticPipe.Resize(Custom{UnknownSizeBitmap}, int, int, ImageResizerTransform.ResizingKind, ImageResizerTransform.Anchor)"/>
             private sealed class Reconciler : EstimatorReconciler
             {
                 public static Reconciler Inst = new Reconciler();
diff --git a/src/Microsoft.ML.ImageAnalytics/ImageStaticPipe.cs b/src/Microsoft.ML.ImageAnalytics/ImageStaticPipe.cs
index 829aca3179..daf94f2bc0 100644
--- a/src/Microsoft.ML.ImageAnalytics/ImageStaticPipe.cs
+++ b/src/Microsoft.ML.ImageAnalytics/ImageStaticPipe.cs
@@ -29,7 +29,7 @@ public static class ImageStaticPipe
         /// safe for users to simply always make their input paths absolute.</param>
         /// <returns>The loaded images</returns>
         /// <seealso cref="ImageLoaderEstimator"/>
-        public static Scalar<UnknownSizeBitmap> LoadAsImage(this Scalar<string> path, string relativeTo = null)
+        public static Custom<UnknownSizeBitmap> LoadAsImage(this Scalar<string> path, string relativeTo = null)
         {
             Contracts.CheckValue(path, nameof(path));
             Contracts.CheckValueOrNull(relativeTo);
@@ -42,7 +42,7 @@ public static Scalar<UnknownSizeBitmap> LoadAsImage(this Scalar<string> path, st
         /// <param name="input">The image to convert</param>
         /// <returns>The grayscale images</returns>
         /// <seealso cref="ImageGrayscaleEstimator"/>
-        public static Scalar<UnknownSizeBitmap> AsGrayscale(this Scalar<UnknownSizeBitmap> input)
+        public static Custom<UnknownSizeBitmap> AsGrayscale(this Custom<UnknownSizeBitmap> input)
         {
             Contracts.CheckValue(input, nameof(input));
             return new ImageGrayscaleEstimator.OutPipelineColumn<UnknownSizeBitmap>(input);
@@ -54,7 +54,7 @@ public static Scalar<UnknownSizeBitmap> AsGrayscale(this Scalar<UnknownSizeBitma
         /// <param name="input">The image to convert</param>
         /// <returns>The grayscale images</returns>
         /// <seealso cref="ImageGrayscaleEstimator"/>
-        public static Scalar<Bitmap> AsGrayscale(this Scalar<Bitmap> input)
+        public static Custom<Bitmap> AsGrayscale(this Custom<Bitmap> input)
         {
             Contracts.CheckValue(input, nameof(input));
             return new ImageGrayscaleEstimator.OutPipelineColumn<Bitmap>(input);
@@ -70,7 +70,7 @@ public static Scalar<Bitmap> AsGrayscale(this Scalar<Bitmap> input)
         /// <param name="cropAnchor">If cropping is necessary, at what position will the image be fixed?</param>
         /// <returns>The now uniformly sized images</returns>
         /// <seealso cref="ImageResizerEstimator"/>
-        public static Scalar<Bitmap> Resize(this Scalar<UnknownSizeBitmap> input, int width, int height,
+        public static Custom<Bitmap> Resize(this Custom<UnknownSizeBitmap> input, int width, int height,
             ImageResizerTransform.ResizingKind resizing = ImageResizerTransform.ResizingKind.IsoCrop,
             ImageResizerTransform.Anchor cropAnchor = ImageResizerTransform.Anchor.Center)
         {
@@ -93,7 +93,7 @@ public static Scalar<Bitmap> Resize(this Scalar<UnknownSizeBitmap> input, int wi
         /// <param name="cropAnchor">If cropping is necessary, at what </param>
         /// <returns>The resized images</returns>
         /// <seealso cref="ImageResizerEstimator"/>
-        public static Scalar<Bitmap> Resize(this Scalar<Bitmap> input, int width, int height,
+        public static Custom<Bitmap> Resize(this Custom<Bitmap> input, int width, int height,
             ImageResizerTransform.ResizingKind resizing = ImageResizerTransform.ResizingKind.IsoCrop,
             ImageResizerTransform.Anchor cropAnchor = ImageResizerTransform.Anchor.Center)
         {
@@ -121,7 +121,7 @@ public static Scalar<Bitmap> Resize(this Scalar<Bitmap> input, int width, int he
         /// <param name="offset">Add this amount to the pixel values, before scaling</param>
         /// <returns>The vectorized image</returns>
         /// <seealso cref="ImagePixelExtractorEstimator"/>
-        public static Vector<float> ExtractPixels(this Scalar<Bitmap> input, bool useAlpha = false, bool useRed = true,
+        public static Vector<float> ExtractPixels(this Custom<Bitmap> input, bool useAlpha = false, bool useRed = true,
             bool useGreen = true, bool useBlue = true, bool interleaveArgb = false, float scale = 1.0f, float offset = 0.0f)
         {
             var colParams = new ImagePixelExtractorTransform.Column
@@ -151,7 +151,7 @@ public static Vector<float> ExtractPixels(this Scalar<Bitmap> input, bool useAlp
         /// <param name="interleaveArgb">Whether the pixel values should be interleaved, as opposed to being separated by channel</param>
         /// <returns>The vectorized image</returns>
         /// <seealso cref="ImagePixelExtractorEstimator"/>
-        public static Vector<byte> ExtractPixelsAsBytes(this Scalar<Bitmap> input, bool useAlpha = false, bool useRed = true,
+        public static Vector<byte> ExtractPixelsAsBytes(this Custom<Bitmap> input, bool useAlpha = false, bool useRed = true,
             bool useGreen = true, bool useBlue = true, bool interleaveArgb = false)
         {
             var colParams = new ImagePixelExtractorTransform.Column
diff --git a/test/Microsoft.ML.StaticPipelineTesting/ImageAnalyticsTests.cs b/test/Microsoft.ML.StaticPipelineTesting/ImageAnalyticsTests.cs
index ad29dbfde5..ea6fee04d3 100644
--- a/test/Microsoft.ML.StaticPipelineTesting/ImageAnalyticsTests.cs
+++ b/test/Microsoft.ML.StaticPipelineTesting/ImageAnalyticsTests.cs
@@ -35,6 +35,11 @@ public void SimpleImageSmokeTest()
             Assert.Equal(3, vecType.GetDim(0));
             Assert.Equal(8, vecType.GetDim(1));
             Assert.Equal(10, vecType.GetDim(2));
+
+            var readAsImage = TextLoader.CreateReader(env,
+                ctx => ctx.LoadText(0).LoadAsImage());
+            var est = readAsImage.MakeNewEstimator().Append(r => r.AsGrayscale().Resize(10, 8).ExtractPixels());
+            var pipe= readAsImage.Append(est);
         }
     }
 }