Searched refs:BigQueryTableAccessor (Results 1 – 4 of 4) sorted by relevance
43 BigQueryTableAccessor::ColumnType* enum_type) { in ParseColumnType()45 *enum_type = BigQueryTableAccessor::ColumnType::kRecord; in ParseColumnType()47 *enum_type = BigQueryTableAccessor::ColumnType::kString; in ParseColumnType()49 *enum_type = BigQueryTableAccessor::ColumnType::kBytes; in ParseColumnType()51 *enum_type = BigQueryTableAccessor::ColumnType::kInteger; in ParseColumnType()53 *enum_type = BigQueryTableAccessor::ColumnType::kFloat; in ParseColumnType()55 *enum_type = BigQueryTableAccessor::ColumnType::kBoolean; in ParseColumnType()57 *enum_type = BigQueryTableAccessor::ColumnType::kTimestamp; in ParseColumnType()59 *enum_type = BigQueryTableAccessor::ColumnType::kDate; in ParseColumnType()61 *enum_type = BigQueryTableAccessor::ColumnType::kTime; in ParseColumnType()[all …]
41 class BigQueryTableAccessor {70 std::unique_ptr<BigQueryTableAccessor>* accessor);88 virtual ~BigQueryTableAccessor() {} in ~BigQueryTableAccessor()113 std::unique_ptr<BigQueryTableAccessor>* accessor);116 BigQueryTableAccessor(140 const BigQueryTableAccessor::ColumnType type,197 TF_DISALLOW_COPY_AND_ASSIGN(BigQueryTableAccessor);
64 BigQueryTableAccessor::SchemaNode GetSchema() { in GetSchema()73 return BigQueryTableAccessor::New( in CreateTableAccessor()82 std::unique_ptr<BigQueryTableAccessor> accessor_;140 EXPECT_EQ(schema_root.type, BigQueryTableAccessor::ColumnType::kNone);145 BigQueryTableAccessor::ColumnType::kInteger);149 BigQueryTableAccessor::ColumnType::kString);154 BigQueryTableAccessor::ColumnType::kRecord);159 BigQueryTableAccessor::ColumnType::kFloat);163 BigQueryTableAccessor::ColumnType::kBoolean);167 BigQueryTableAccessor::ColumnType::kBytes);[all …]
54 explicit BigQueryReader(BigQueryTableAccessor* bigquery_table_accessor, in BigQueryReader()90 BigQueryTableAccessor* bigquery_table_accessor_;108 BigQueryTableAccessor::New( in BigQueryReaderOp()119 std::unique_ptr<BigQueryTableAccessor> bigquery_table_accessor_;140 BigQueryTableAccessor::New( in GenerateBigQueryReaderPartitionsOp()185 std::unique_ptr<BigQueryTableAccessor> bigquery_table_accessor_;