diff --git a/firestore-bigquery-export/scripts/import/src/run-multi-thread.ts b/firestore-bigquery-export/scripts/import/src/run-multi-thread.ts index f4d40ae4b..6ab3d1530 100644 --- a/firestore-bigquery-export/scripts/import/src/run-multi-thread.ts +++ b/firestore-bigquery-export/scripts/import/src/run-multi-thread.ts @@ -5,12 +5,6 @@ import { pool } from "workerpool"; import * as logs from "./logs"; import { CliConfig } from "./types"; -// import { -// ChangeType, -// FirestoreBigQueryEventHistoryTracker, -// FirestoreDocumentChangeEvent, -// } from "@firebaseextensions/firestore-bigquery-change-tracker"; - /** * Import data from a collection group in parallel using workers. */ @@ -96,16 +90,3 @@ export async function runMultiThread(config: CliConfig): Promise { return Promise.resolve(total); } - -// export async function runMultiThread( -// config: CliConfig, -// dataSink: FirestoreBigQueryEventHistoryTracker -// ): Promise { -// const { -// datasetId, -// datasetLocation, -// rawChangeLogName, -// } = config; - -// return processCollectionGroup(config) -// } diff --git a/firestore-bigquery-export/scripts/import/src/run-single-thread.ts b/firestore-bigquery-export/scripts/import/src/run-single-thread.ts index 222adb9fa..38157d07f 100644 --- a/firestore-bigquery-export/scripts/import/src/run-single-thread.ts +++ b/firestore-bigquery-export/scripts/import/src/run-single-thread.ts @@ -7,14 +7,10 @@ import * as firebase from "firebase-admin"; import * as fs from "fs"; import * as util from "util"; -import { resolveWildcardIds } from "./config"; import { getRowsFromDocs } from "./helper"; import { CliConfig } from "./types"; const write = util.promisify(fs.writeFile); - -const FIRESTORE_DEFAULT_DATABASE = "(default)"; - export function getQuery( config: CliConfig, cursor?: firebase.firestore.DocumentSnapshot