Class ParquetSourceReads data from a parquet source. While reading the data from the file, data is also asynchronously posted into the targets.InheritanceobjectLoggableTaskDataFlowComponentDataFlowSource<ExpandoObject>DataFlowExecutableSource<ExpandoObject>DataFlowStreamSource<ExpandoObject>ParquetSource<ExpandoObject>ParquetSourceImplementsIDataFlowStreamSource<ExpandoObject>IDataFlowExecutableSource<ExpandoObject>IDataFlowSource<ExpandoObject>IDataFlowStreamSourceIDataFlowExecutableSourceIDataFlowSourceIDataFlowComponentILoggableTaskInherited MembersParquetSource<ExpandoObject>.ParquetColumnsParquetSource<ExpandoObject>.ParquetOptionsParquetSource<ExpandoObject>.SupportedDataTypesParquetSource<ExpandoObject>.Reset()ParquetSource<ExpandoObject>.PrepareParameterForCheck()ParquetSource<ExpandoObject>.CheckParameter()ParquetSource<ExpandoObject>.InitReader()ParquetSource<ExpandoObject>.ReadAllRecords()ParquetSource<ExpandoObject>.FindPropNameMapping(string)ParquetSource<ExpandoObject>.CloseReader()DataFlowStreamSource<ExpandoObject>.UriDataFlowStreamSource<ExpandoObject>.GetNextUriDataFlowStreamSource<ExpandoObject>.HasNextUriDataFlowStreamSource<ExpandoObject>.ResourceTypeDataFlowStreamSource<ExpandoObject>.HttpClientDataFlowStreamSource<ExpandoObject>.HttpRequestMessageDataFlowStreamSource<ExpandoObject>.HttpResponseMessageDataFlowStreamSource<ExpandoObject>.EncodingDataFlowStreamSource<ExpandoObject>.UnparsedDataDataFlowStreamSource<ExpandoObject>.CollectUnparsedDataDataFlowStreamSource<ExpandoObject>.CreateStreamReaderDataFlowStreamSource<ExpandoObject>.AzureBlobStorageDataFlowStreamSource<ExpandoObject>.SkipRowsDataFlowStreamSource<ExpandoObject>.RequestUriDataFlowStreamSource<ExpandoObject>.StreamReaderDataFlowStreamSource<ExpandoObject>.RowModificationActionDataFlowStreamSource<ExpandoObject>.UseMulitpartContentDataFlowStreamSource<ExpandoObject>.UnparsedDataBuilderDataFlowStreamSource<ExpandoObject>.OnExecutionDoAsyncWork()DataFlowStreamSource<ExpandoObject>.CleanUpOnSuccess()DataFlowStreamSource<ExpandoObject>.CleanUpOnFaulted(Exception)DataFlowStreamSource<ExpandoObject>.NewMetaDataObjectDataFlowExecutableSource<ExpandoObject>.LimitDataFlowExecutableSource<ExpandoObject>.ProgressCountIsInLimitDataFlowExecutableSource<ExpandoObject>.ProgressCountIsExceedingLimitDataFlowExecutableSource<ExpandoObject>.SourceBlockDataFlowExecutableSource<ExpandoObject>.BufferDataFlowExecutableSource<ExpandoObject>.SourceTaskDataFlowExecutableSource<ExpandoObject>.CompleteManuallyDataFlowExecutableSource<ExpandoObject>.InitComponent()DataFlowExecutableSource<ExpandoObject>.Execute()DataFlowExecutableSource<ExpandoObject>.Execute(CancellationToken)DataFlowExecutableSource<ExpandoObject>.ExecuteAsync()DataFlowExecutableSource<ExpandoObject>.ExecuteAsync(CancellationToken)DataFlowExecutableSource<ExpandoObject>.StartAsync(CancellationToken?)DataFlowSource<ExpandoObject>.LinkTo(IDataFlowDestination<ExpandoObject>)DataFlowSource<ExpandoObject>.LinkTo(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>)DataFlowSource<ExpandoObject>.LinkTo(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>, Predicate<ExpandoObject>)DataFlowSource<ExpandoObject>.LinkTo<TConvert>(IDataFlowDestination<ExpandoObject>)DataFlowSource<ExpandoObject>.LinkTo<TConvert>(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>)DataFlowSource<ExpandoObject>.LinkTo<TConvert>(IDataFlowDestination<ExpandoObject>, Predicate<ExpandoObject>, Predicate<ExpandoObject>)DataFlowComponent.MaxBufferSizeDataFlowComponent.PredecessorsDataFlowComponent.SuccessorsDataFlowComponent.CompletionDataFlowComponent.BufferCancellationSourceDataFlowComponent.BufferCancellationTokenDataFlowComponent.WasComponentInitializedDataFlowComponent.IsReadyForProcessingDataFlowComponent.SetParentComponent(DataFlowComponent)DataFlowComponent.LinkErrorTo(IDataFlowDestination<ETLBoxError>)DataFlowComponent.InternalLinkTo<T>(IDataFlowDestination, object, object)DataFlowComponent.AddAutomaticVoidLinkToOtherTargets(DataFlowComponent, IDataFlowDestination)DataFlowComponent.ResetComponent()DataFlowComponent.InitBufferObjects(CancellationToken?)DataFlowComponent.InitCheckedParameter()DataFlowComponent.OnInitializationDataFlowComponent.OnCompletionDataFlowComponent.OnExceptionDataFlowComponent.CompleteOrFaultBufferOnPredecessorCompletion(Task)DataFlowComponent.ExceptionDataFlowComponent.ErrorSourceDataFlowComponent.CancelBufferAndThrowOperationCanceledException()DataFlowComponent.InternalLinkErrorTo(IDataFlowDestination<ETLBoxError>)DataFlowComponent.ThrowOrRedirectError(Exception, string, string)DataFlowComponent.ThrowErrorAndFaultNetwork(Exception, string)DataFlowComponent.CancelComponent()DataFlowComponent.ErrorCountDataFlowComponent.ProgressCountDataFlowComponent.OnProgressDataFlowComponent.ExecutionStartTimeDataFlowComponent.ExecutionEndTimeDataFlowComponent.TagDataFlowComponent.LoggingStartOnce()DataFlowComponent.LoggingFinishOnce()DataFlowComponent.LogProgressBatch_AfterThrowOrRedirectError(int)DataFlowComponent.LogProgress_AfterThrowOrRedirectError()LoggableTask.TaskTypeLoggableTask.TaskNameLoggableTask.DisableLoggingLoggableTask.LogThresholdLoggableTask.TaskHashLoggableTask.LogInstanceLoggableTask.ParentTaskLoggableTask.LogTrace(string, params object[])LoggableTask.LogDebug(string, params object[])LoggableTask.LogInfo(string, params object[])LoggableTask.LogInfoOrDebug(string, params object[])LoggableTask.LogWarn(string, params object[])LoggableTask.LogError(string, params object[])LoggableTask.LogFatal(string, params object[])object.Equals(object)object.Equals(object, object)object.GetHashCode()object.GetType()object.MemberwiseClone()object.ReferenceEquals(object, object)object.ToString()Namespace: ETLBox.ParquetAssembly: ETLBox.Parquet.dllSyntax# public class ParquetSource : ParquetSource<ExpandoObject>, IDataFlowStreamSource<ExpandoObject>, IDataFlowExecutableSource<ExpandoObject>, IDataFlowSource<ExpandoObject>, IDataFlowStreamSource, IDataFlowExecutableSource, IDataFlowSource, IDataFlowComponent, ILoggableTaskConstructorsParquetSource()#Declaration public ParquetSource()ParquetSource(string)#Declaration public ParquetSource(string uri)ParametersTypeNameDescriptionstringuriParquetSource(string, ResourceType)#Declaration public ParquetSource(string uri, ResourceType resourceType)ParametersTypeNameDescriptionstringuriResourceTyperesourceTypeImplements#IDataFlowStreamSource<TOutput>IDataFlowExecutableSource<TOutput>IDataFlowSource<TOutput>IDataFlowStreamSourceIDataFlowExecutableSourceIDataFlowSourceIDataFlowComponentILoggableTaskPrevParquetSource<TOutput>NextPivotColumn