@@ -65,7 +65,7 @@ export class FirestoreBigQueryEventHistoryTracker implements FirestoreEventHisto
65
65
/**
66
66
* Inserts rows of data into the BigQuery raw change log table.
67
67
*/
68
- async insertData ( rows : bigquery . RowMetadata [ ] ) {
68
+ private async insertData ( rows : bigquery . RowMetadata [ ] ) {
69
69
try {
70
70
const dataset = this . bq . dataset ( this . config . datasetId ) ;
71
71
const table = dataset . table ( this . rawChangeLogTableName ( ) ) ;
@@ -83,7 +83,7 @@ export class FirestoreBigQueryEventHistoryTracker implements FirestoreEventHisto
83
83
* Creates the BigQuery resources with the expected schema for {@link FirestoreEventHistoryTracker}.
84
84
* After the first invokation, it skips initialization assuming these resources are still there.
85
85
*/
86
- async initialize ( ) {
86
+ private async initialize ( ) {
87
87
if ( this . initialized ) {
88
88
return ;
89
89
}
@@ -96,7 +96,7 @@ export class FirestoreBigQueryEventHistoryTracker implements FirestoreEventHisto
96
96
/**
97
97
* Creates the specified dataset if it doesn't already exists.
98
98
*/
99
- async initializeDataset ( ) {
99
+ private async initializeDataset ( ) {
100
100
const dataset = this . bq . dataset ( this . config . datasetId ) ;
101
101
const [ datasetExists ] = await dataset . exists ( ) ;
102
102
if ( datasetExists ) {
@@ -113,7 +113,7 @@ export class FirestoreBigQueryEventHistoryTracker implements FirestoreEventHisto
113
113
* Creates the raw change log table if it doesn't already exist.
114
114
* TODO: Validate that the BigQuery schema is correct if the table does exist,
115
115
*/
116
- async initializeRawChangeLogTable ( ) {
116
+ private async initializeRawChangeLogTable ( ) {
117
117
const changelogName = this . rawChangeLogTableName ( ) ;
118
118
const dataset = this . bq . dataset ( this . config . datasetId ) ;
119
119
const table = dataset . table ( changelogName ) ;
@@ -138,7 +138,7 @@ export class FirestoreBigQueryEventHistoryTracker implements FirestoreEventHisto
138
138
* Creates the latest snapshot view, which returns only latest operations
139
139
* of all existing documents over the raw change log table.
140
140
*/
141
- async initializeLatestView ( ) {
141
+ private async initializeLatestView ( ) {
142
142
const dataset = this . bq . dataset ( this . config . datasetId ) ;
143
143
const view = dataset . table ( this . rawLatestView ( ) ) ;
144
144
const [ viewExists ] = await view . exists ( ) ;
0 commit comments