Skip to content

Commit fde8f97

Browse files
committed
sync with java: d3ec2c31bb8774b8cf3e07b3df4a759b277da483
1 parent 2e61589 commit fde8f97

17 files changed

+399
-89
lines changed
Lines changed: 5 additions & 33 deletions
Original file line numberDiff line numberDiff line change
@@ -1,36 +1,8 @@
1-
import { AbstractGenericCountersIndexCreationTask } from "./AbstractGenericCountersIndexCreationTask";
2-
import { CountersIndexDefinition } from "./CountersIndexDefinition";
3-
import { CountersIndexDefinitionBuilder } from "./CountersIndexDefinitionBuilder";
4-
import { DocumentConventions } from "../../Conventions/DocumentConventions";
1+
import { AbstractCsharpCountersIndexCreationTask } from "./AbstractCsharpCountersIndexCreationTask";
52

6-
export class AbstractCountersIndexCreationTask extends AbstractGenericCountersIndexCreationTask {
7-
public map: string;
3+
/**
4+
* @deprecated Use AbstractCsharpCountersIndexCreationTask
5+
*/
6+
export abstract class AbstractCountersIndexCreationTask extends AbstractCsharpCountersIndexCreationTask {
87

9-
createIndexDefinition(): CountersIndexDefinition {
10-
if (!this.conventions) {
11-
this.conventions = new DocumentConventions();
12-
}
13-
14-
const indexDefinitionBuilder = new CountersIndexDefinitionBuilder(this.getIndexName());
15-
indexDefinitionBuilder.indexesStrings = this._indexesStrings;
16-
indexDefinitionBuilder.analyzersStrings = this._analyzersStrings;
17-
indexDefinitionBuilder.map = this.map;
18-
indexDefinitionBuilder.reduce = this._reduce;
19-
indexDefinitionBuilder.storesStrings = this._storesStrings;
20-
indexDefinitionBuilder.suggestionsOptions = this._indexSuggestions;
21-
indexDefinitionBuilder.termVectorsStrings = this._termVectorsStrings;
22-
indexDefinitionBuilder.spatialIndexesStrings = this._spatialOptionsStrings;
23-
indexDefinitionBuilder.outputReduceToCollection = this._outputReduceToCollection;
24-
indexDefinitionBuilder.patternForOutputReduceToCollectionReferences = this._patternForOutputReduceToCollectionReferences;
25-
indexDefinitionBuilder.patternReferencesCollectionName = this._patternReferencesCollectionName;
26-
indexDefinitionBuilder.additionalSources = this.additionalSources;
27-
indexDefinitionBuilder.additionalAssemblies = this.additionalAssemblies;
28-
indexDefinitionBuilder.configuration = this.configuration;
29-
indexDefinitionBuilder.lockMode = this.lockMode;
30-
indexDefinitionBuilder.priority = this.priority;
31-
indexDefinitionBuilder.state = this.state;
32-
indexDefinitionBuilder.deploymentMode = this.deploymentMode;
33-
34-
return indexDefinitionBuilder.toIndexDefinition(this.conventions);
35-
}
368
}
Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,36 @@
1+
import { AbstractGenericCountersIndexCreationTask } from "./AbstractGenericCountersIndexCreationTask";
2+
import { CountersIndexDefinition } from "./CountersIndexDefinition";
3+
import { CountersIndexDefinitionBuilder } from "./CountersIndexDefinitionBuilder";
4+
import { DocumentConventions } from "../../Conventions/DocumentConventions";
5+
6+
export abstract class AbstractCsharpCountersIndexCreationTask extends AbstractGenericCountersIndexCreationTask {
7+
public map: string;
8+
9+
createIndexDefinition(): CountersIndexDefinition {
10+
if (!this.conventions) {
11+
this.conventions = new DocumentConventions();
12+
}
13+
14+
const indexDefinitionBuilder = new CountersIndexDefinitionBuilder(this.getIndexName());
15+
indexDefinitionBuilder.indexesStrings = this._indexesStrings;
16+
indexDefinitionBuilder.analyzersStrings = this._analyzersStrings;
17+
indexDefinitionBuilder.map = this.map;
18+
indexDefinitionBuilder.reduce = this._reduce;
19+
indexDefinitionBuilder.storesStrings = this._storesStrings;
20+
indexDefinitionBuilder.suggestionsOptions = this._indexSuggestions;
21+
indexDefinitionBuilder.termVectorsStrings = this._termVectorsStrings;
22+
indexDefinitionBuilder.spatialIndexesStrings = this._spatialOptionsStrings;
23+
indexDefinitionBuilder.outputReduceToCollection = this._outputReduceToCollection;
24+
indexDefinitionBuilder.patternForOutputReduceToCollectionReferences = this._patternForOutputReduceToCollectionReferences;
25+
indexDefinitionBuilder.patternReferencesCollectionName = this._patternReferencesCollectionName;
26+
indexDefinitionBuilder.additionalSources = this.additionalSources;
27+
indexDefinitionBuilder.additionalAssemblies = this.additionalAssemblies;
28+
indexDefinitionBuilder.configuration = this.configuration;
29+
indexDefinitionBuilder.lockMode = this.lockMode;
30+
indexDefinitionBuilder.priority = this.priority;
31+
indexDefinitionBuilder.state = this.state;
32+
indexDefinitionBuilder.deploymentMode = this.deploymentMode;
33+
34+
return indexDefinitionBuilder.toIndexDefinition(this.conventions);
35+
}
36+
}

src/Documents/Indexes/Counters/AbstractMultiMapCountersIndexCreationTask.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import { CountersIndexDefinition } from "./CountersIndexDefinition";
44
import { CountersIndexDefinitionBuilder } from "./CountersIndexDefinitionBuilder";
55
import { DocumentConventions } from "../../Conventions/DocumentConventions";
66

7-
export class AbstractMultiMapCountersIndexCreationTask extends AbstractGenericCountersIndexCreationTask {
7+
export abstract class AbstractMultiMapCountersIndexCreationTask extends AbstractGenericCountersIndexCreationTask {
88
private readonly maps: string[] = [];
99

1010
protected _addMap(map: string) {
Lines changed: 104 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,104 @@
1+
import { CountersIndexDefinition } from "./CountersIndexDefinition";
2+
import { AbstractIndexCreationTaskBase } from "../AbstractIndexCreationTaskBase";
3+
import { IndexDefinition } from "../IndexDefinition";
4+
5+
export abstract class AbstractRawJavaScriptCountersIndexCreationTask extends AbstractIndexCreationTaskBase<CountersIndexDefinition> {
6+
7+
private readonly _definition = new CountersIndexDefinition();
8+
9+
protected constructor() {
10+
super();
11+
}
12+
13+
public get maps() {
14+
return this._definition.maps;
15+
}
16+
17+
public set maps(value) {
18+
this._definition.maps = value;
19+
}
20+
21+
public get fields() {
22+
return this._definition.fields;
23+
}
24+
25+
public set fields(value) {
26+
this._definition.fields = value;
27+
}
28+
29+
public get reduce() {
30+
return this._definition.reduce;
31+
}
32+
33+
public set reduce(value) {
34+
this._definition.reduce = value;
35+
}
36+
37+
public get isMapReduce(): boolean {
38+
return !!this.reduce;
39+
}
40+
41+
/**
42+
* @return If not null than each reduce result will be created as a document in the specified collection name.
43+
*/
44+
public get outputReduceToCollection() {
45+
return this._definition.outputReduceToCollection;
46+
}
47+
48+
/**
49+
* @param value If not null than each reduce result will be created as a document in the specified collection name.
50+
*/
51+
public set outputReduceToCollection(value) {
52+
this._definition.outputReduceToCollection = value;
53+
}
54+
55+
/**
56+
* @return Defines a collection name for reference documents created based on provided pattern
57+
*/
58+
public get patternReferencesCollectionName() {
59+
return this._definition.patternReferencesCollectionName;
60+
}
61+
62+
/**
63+
* @param value Defines a collection name for reference documents created based on provided pattern
64+
*/
65+
public set patternReferencesCollectionName(value: string) {
66+
this._definition.patternReferencesCollectionName = value;
67+
}
68+
69+
/**
70+
* @return Defines a collection name for reference documents created based on provided pattern
71+
*/
72+
public get patternForOutputReduceToCollectionReferences() {
73+
return this._definition.patternForOutputReduceToCollectionReferences;
74+
}
75+
76+
/**
77+
* @param value Defines a collection name for reference documents created based on provided pattern
78+
*/
79+
public set patternForOutputReduceToCollectionReferences(value: string) {
80+
this._definition.patternForOutputReduceToCollectionReferences = value;
81+
}
82+
83+
public createIndexDefinition(): IndexDefinition {
84+
this._definition.name = this.getIndexName();
85+
this._definition.type = this.isMapReduce ? "JavaScriptMapReduce" : "JavaScriptMap";
86+
this._definition.name = this.getIndexName();
87+
88+
if (this.additionalSources) {
89+
this._definition.additionalSources = this.additionalSources;
90+
} else {
91+
this._definition.additionalSources = {};
92+
}
93+
94+
this._definition.additionalAssemblies = this.additionalAssemblies || [];
95+
96+
this._definition.configuration = this.configuration;
97+
this._definition.lockMode = this.lockMode;
98+
this._definition.priority = this.priority;
99+
this._definition.state = this.state;
100+
this._definition.deploymentMode = this.deploymentMode;
101+
102+
return this._definition;
103+
}
104+
}
Lines changed: 37 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,37 @@
1+
import { AbstractGenericTimeSeriesIndexCreationTask } from "./AbstractGenericTimeSeriesIndexCreationTask";
2+
import { TimeSeriesIndexDefinition } from "./TimeSeriesIndexDefinition";
3+
import { TimeSeriesIndexDefinitionBuilder } from "./TimeSeriesIndexDefinitionBuilder";
4+
import { DocumentConventions } from "../../Conventions/DocumentConventions";
5+
import { AbstractTimeSeriesIndexCreationTask } from "./AbstractTimeSeriesIndexCreationTask";
6+
7+
export abstract class AbstractCsharpTimeSeriesIndexCreationTask extends AbstractGenericTimeSeriesIndexCreationTask {
8+
public map: string;
9+
10+
createIndexDefinition(): TimeSeriesIndexDefinition {
11+
if (!this.conventions) {
12+
this.conventions = new DocumentConventions();
13+
}
14+
15+
const indexDefinitionBuilder = new TimeSeriesIndexDefinitionBuilder(this.getIndexName());
16+
indexDefinitionBuilder.indexesStrings = this._indexesStrings;
17+
indexDefinitionBuilder.analyzersStrings = this._analyzersStrings;
18+
indexDefinitionBuilder.map = this.map;
19+
indexDefinitionBuilder.reduce = this._reduce;
20+
indexDefinitionBuilder.storesStrings = this._storesStrings;
21+
indexDefinitionBuilder.suggestionsOptions = this._indexSuggestions;
22+
indexDefinitionBuilder.termVectorsStrings = this._termVectorsStrings;
23+
indexDefinitionBuilder.spatialIndexesStrings = this._spatialOptionsStrings;
24+
indexDefinitionBuilder.outputReduceToCollection = this._outputReduceToCollection;
25+
indexDefinitionBuilder.patternForOutputReduceToCollectionReferences = this._patternForOutputReduceToCollectionReferences;
26+
indexDefinitionBuilder.patternReferencesCollectionName = this._patternReferencesCollectionName;
27+
indexDefinitionBuilder.additionalSources = this.additionalSources;
28+
indexDefinitionBuilder.additionalAssemblies = this.additionalAssemblies;
29+
indexDefinitionBuilder.configuration = this.configuration;
30+
indexDefinitionBuilder.lockMode = this.lockMode;
31+
indexDefinitionBuilder.priority = this.priority;
32+
indexDefinitionBuilder.state = this.state;
33+
indexDefinitionBuilder.deploymentMode = this.deploymentMode;
34+
35+
return indexDefinitionBuilder.toIndexDefinition(this.conventions);
36+
}
37+
}

src/Documents/Indexes/TimeSeries/AbstractMultiMapTimeSeriesIndexCreationTask.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -4,7 +4,7 @@ import { TimeSeriesIndexDefinition } from "./TimeSeriesIndexDefinition";
44
import { AbstractGenericTimeSeriesIndexCreationTask } from "./AbstractGenericTimeSeriesIndexCreationTask";
55
import { DocumentConventions } from "../../Conventions/DocumentConventions";
66

7-
export class AbstractMultiMapTimeSeriesIndexCreationTask extends AbstractGenericTimeSeriesIndexCreationTask {
7+
export abstract class AbstractMultiMapTimeSeriesIndexCreationTask extends AbstractGenericTimeSeriesIndexCreationTask {
88
private readonly maps: string[] = [];
99

1010
protected _addMap(map: string) {
Lines changed: 104 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,104 @@
1+
import { AbstractIndexCreationTaskBase } from "../AbstractIndexCreationTaskBase";
2+
import { TimeSeriesIndexDefinition } from "./TimeSeriesIndexDefinition";
3+
import { IndexDefinition } from "../IndexDefinition";
4+
5+
export abstract class AbstractRawJavaScriptTimeSeriesIndexCreationTask extends AbstractIndexCreationTaskBase<TimeSeriesIndexDefinition> {
6+
private readonly _definition = new TimeSeriesIndexDefinition();
7+
8+
protected constructor() {
9+
super();
10+
}
11+
12+
public get maps() {
13+
return this._definition.maps;
14+
}
15+
16+
public set maps(value) {
17+
this._definition.maps = value;
18+
}
19+
20+
public get fields() {
21+
return this._definition.fields;
22+
}
23+
24+
public set fields(value) {
25+
this._definition.fields = value;
26+
}
27+
28+
public get reduce() {
29+
return this._definition.reduce;
30+
}
31+
32+
public set reduce(value) {
33+
this._definition.reduce = value;
34+
}
35+
36+
public get isMapReduce(): boolean {
37+
return !!this.reduce;
38+
}
39+
40+
41+
/**
42+
* @return If not null than each reduce result will be created as a document in the specified collection name.
43+
*/
44+
public get outputReduceToCollection() {
45+
return this._definition.outputReduceToCollection;
46+
}
47+
48+
/**
49+
* @param value If not null than each reduce result will be created as a document in the specified collection name.
50+
*/
51+
public set outputReduceToCollection(value) {
52+
this._definition.outputReduceToCollection = value;
53+
}
54+
55+
/**
56+
* @return Defines a collection name for reference documents created based on provided pattern
57+
*/
58+
public get patternReferencesCollectionName() {
59+
return this._definition.patternReferencesCollectionName;
60+
}
61+
62+
/**
63+
* @param value Defines a collection name for reference documents created based on provided pattern
64+
*/
65+
public set patternReferencesCollectionName(value: string) {
66+
this._definition.patternReferencesCollectionName = value;
67+
}
68+
69+
/**
70+
* @return Defines a collection name for reference documents created based on provided pattern
71+
*/
72+
public get patternForOutputReduceToCollectionReferences() {
73+
return this._definition.patternForOutputReduceToCollectionReferences;
74+
}
75+
76+
/**
77+
* @param value Defines a collection name for reference documents created based on provided pattern
78+
*/
79+
public set patternForOutputReduceToCollectionReferences(value: string) {
80+
this._definition.patternForOutputReduceToCollectionReferences = value;
81+
}
82+
83+
public createIndexDefinition(): IndexDefinition {
84+
this._definition.name = this.getIndexName();
85+
this._definition.type = this.isMapReduce ? "JavaScriptMapReduce" : "JavaScriptMap";
86+
this._definition.name = this.getIndexName();
87+
88+
if (this.additionalSources) {
89+
this._definition.additionalSources = this.additionalSources;
90+
} else {
91+
this._definition.additionalSources = {};
92+
}
93+
94+
this._definition.additionalAssemblies = this.additionalAssemblies || [];
95+
96+
this._definition.configuration = this.configuration;
97+
this._definition.lockMode = this.lockMode;
98+
this._definition.priority = this.priority;
99+
this._definition.state = this.state;
100+
this._definition.deploymentMode = this.deploymentMode;
101+
102+
return this._definition;
103+
}
104+
}
Lines changed: 5 additions & 34 deletions
Original file line numberDiff line numberDiff line change
@@ -1,36 +1,7 @@
1-
import { AbstractGenericTimeSeriesIndexCreationTask } from "./AbstractGenericTimeSeriesIndexCreationTask";
2-
import { TimeSeriesIndexDefinition } from "./TimeSeriesIndexDefinition";
3-
import { TimeSeriesIndexDefinitionBuilder } from "./TimeSeriesIndexDefinitionBuilder";
4-
import { DocumentConventions } from "../../Conventions/DocumentConventions";
1+
import { AbstractCsharpCountersIndexCreationTask } from "../Counters/AbstractCsharpCountersIndexCreationTask";
52

6-
export abstract class AbstractTimeSeriesIndexCreationTask extends AbstractGenericTimeSeriesIndexCreationTask {
7-
public map: string;
8-
9-
createIndexDefinition(): TimeSeriesIndexDefinition {
10-
if (!this.conventions) {
11-
this.conventions = new DocumentConventions();
12-
}
13-
14-
const indexDefinitionBuilder = new TimeSeriesIndexDefinitionBuilder(this.getIndexName());
15-
indexDefinitionBuilder.indexesStrings = this._indexesStrings;
16-
indexDefinitionBuilder.analyzersStrings = this._analyzersStrings;
17-
indexDefinitionBuilder.map = this.map;
18-
indexDefinitionBuilder.reduce = this._reduce;
19-
indexDefinitionBuilder.storesStrings = this._storesStrings;
20-
indexDefinitionBuilder.suggestionsOptions = this._indexSuggestions;
21-
indexDefinitionBuilder.termVectorsStrings = this._termVectorsStrings;
22-
indexDefinitionBuilder.spatialIndexesStrings = this._spatialOptionsStrings;
23-
indexDefinitionBuilder.outputReduceToCollection = this._outputReduceToCollection;
24-
indexDefinitionBuilder.patternForOutputReduceToCollectionReferences = this._patternForOutputReduceToCollectionReferences;
25-
indexDefinitionBuilder.patternReferencesCollectionName = this._patternReferencesCollectionName;
26-
indexDefinitionBuilder.additionalSources = this.additionalSources;
27-
indexDefinitionBuilder.additionalAssemblies = this.additionalAssemblies;
28-
indexDefinitionBuilder.configuration = this.configuration;
29-
indexDefinitionBuilder.lockMode = this.lockMode;
30-
indexDefinitionBuilder.priority = this.priority;
31-
indexDefinitionBuilder.state = this.state;
32-
indexDefinitionBuilder.deploymentMode = this.deploymentMode;
33-
34-
return indexDefinitionBuilder.toIndexDefinition(this.conventions);
35-
}
3+
/**
4+
* @deprecated use AbstractCsharpCountersIndexCreationTask
5+
*/
6+
export abstract class AbstractTimeSeriesIndexCreationTask extends AbstractCsharpCountersIndexCreationTask {
367
}

src/Documents/Indexes/index.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,2 +1,4 @@
11
export * from "./AbstractCsharpIndexCreationTask";
22
export * from "./AbstractCsharpMultiMapIndexCreationTask";
3+
export * from "./Counters/AbstractCsharpCountersIndexCreationTask";
4+
export * from "./TimeSeries/AbstractTimeSeriesIndexCreationTask";

0 commit comments

Comments
 (0)