;
constructor(props: DatasourcesViewProps, context: any) {
@@ -312,10 +333,16 @@ ORDER BY 1`;
};
this.datasourceQueryManager = new QueryManager({
- processQuery: async capabilities => {
+ processQuery: async (
+ { capabilities, hiddenColumns, showUnused },
+ _cancelToken,
+ setIntermediateQuery,
+ ) => {
let datasources: DatasourceQueryResultRow[];
if (capabilities.hasSql()) {
- datasources = await queryDruidSql({ query: DatasourcesView.DATASOURCE_SQL });
+ const query = DatasourcesView.query(hiddenColumns);
+ setIntermediateQuery(query);
+ datasources = await queryDruidSql({ query });
} else if (capabilities.hasCoordinatorAccess()) {
const datasourcesResp = await Api.instance.get(
'/druid/coordinator/v1/datasources?simple',
@@ -330,7 +357,6 @@ ORDER BY 1`;
const numSegments = availableSegments + segmentsToLoad;
return {
datasource: d.name,
- num_available_segments: availableSegments,
num_segments: numSegments,
num_segments_to_load: segmentsToLoad,
num_segments_to_drop: 0,
@@ -366,11 +392,9 @@ ORDER BY 1`;
const seen = countBy(datasources, x => x.datasource);
let unused: string[] = [];
- if (this.state.showUnused) {
- // Using 'includeDisabled' parameter for compatibility.
- // Should be changed to 'includeUnused' in Druid 0.17
+ if (showUnused) {
const unusedResp = await Api.instance.get(
- '/druid/coordinator/v1/metadata/datasources?includeDisabled',
+ '/druid/coordinator/v1/metadata/datasources?includeUnused',
);
unused = unusedResp.data.filter((d: string) => !seen[d]);
}
@@ -442,9 +466,15 @@ ORDER BY 1`;
this.tiersQueryManager.rerunLastQuery(auto);
};
+ private fetchDatasourceData() {
+ const { capabilities } = this.props;
+ const { hiddenColumns, showUnused } = this.state;
+ this.datasourceQueryManager.runQuery({ capabilities, hiddenColumns, showUnused });
+ }
+
componentDidMount(): void {
const { capabilities } = this.props;
- this.datasourceQueryManager.runQuery(capabilities);
+ this.fetchDatasourceData();
this.tiersQueryManager.runQuery(capabilities);
window.addEventListener('resize', this.handleResize);
}
@@ -477,7 +507,7 @@ ORDER BY 1`;
this.setState({ datasourceToMarkAsUnusedAllSegmentsIn: undefined });
}}
onSuccess={() => {
- this.datasourceQueryManager.rerunLastQuery();
+ this.fetchDatasourceData();
}}
>
@@ -510,7 +540,7 @@ ORDER BY 1`;
this.setState({ datasourceToMarkAllNonOvershadowedSegmentsAsUsedIn: undefined });
}}
onSuccess={() => {
- this.datasourceQueryManager.rerunLastQuery();
+ this.fetchDatasourceData();
}}
>
{`Are you sure you want to mark as used all non-overshadowed segments in '${datasourceToMarkAllNonOvershadowedSegmentsAsUsedIn}'?`}
@@ -547,7 +577,7 @@ ORDER BY 1`;
this.setState({ datasourceToMarkSegmentsByIntervalIn: undefined });
}}
onSuccess={() => {
- this.datasourceQueryManager.rerunLastQuery();
+ this.fetchDatasourceData();
}}
>
{`Please select the interval in which you want to mark segments as ${usedWord} in '${datasourceToMarkSegmentsByIntervalIn}'?`}
@@ -588,7 +618,7 @@ ORDER BY 1`;
this.setState({ killDatasource: undefined });
}}
onSuccess={() => {
- this.datasourceQueryManager.rerunLastQuery();
+ this.fetchDatasourceData();
}}
warningChecks={[
`I understand that this operation will delete all metadata about the unused segments of ${killDatasource} and removes them from deep storage.`,
@@ -605,6 +635,7 @@ ORDER BY 1`;
renderBulkDatasourceActions() {
const { goToQuery, capabilities } = this.props;
+ const lastDatasourcesQuery = this.datasourceQueryManager.getLastIntermediateQuery();
return (
goToQuery(DatasourcesView.DATASOURCE_SQL)}
+ disabled={!lastDatasourcesQuery}
+ onClick={() => {
+ if (!lastDatasourcesQuery) return;
+ goToQuery(lastDatasourcesQuery);
+ }}
/>
)}
{
@@ -705,7 +740,7 @@ ORDER BY 1`;
try {
await Api.instance.post(`/druid/coordinator/v1/config/compaction`, compactionConfig);
this.setState({ compactionDialogOpenOn: undefined });
- this.datasourceQueryManager.rerunLastQuery();
+ this.fetchDatasourceData();
} catch (e) {
AppToaster.show({
message: getDruidErrorMessage(e),
@@ -728,9 +763,7 @@ ORDER BY 1`;
await Api.instance.delete(
`/druid/coordinator/v1/config/compaction/${Api.encodePath(datasource)}`,
);
- this.setState({ compactionDialogOpenOn: undefined }, () =>
- this.datasourceQueryManager.rerunLastQuery(),
- );
+ this.setState({ compactionDialogOpenOn: undefined }, () => this.fetchDatasourceData());
} catch (e) {
AppToaster.show({
message: getDruidErrorMessage(e),
@@ -743,10 +776,10 @@ ORDER BY 1`;
};
private toggleUnused(showUnused: boolean) {
- if (!showUnused) {
- this.datasourceQueryManager.rerunLastQuery();
- }
- this.setState({ showUnused: !showUnused });
+ this.setState({ showUnused: !showUnused }, () => {
+ if (showUnused) return;
+ this.fetchDatasourceData();
+ });
}
getDatasourceActions(
@@ -979,18 +1012,11 @@ ORDER BY 1`;
{
Header: 'Availability',
show: hiddenColumns.exists('Availability'),
- id: 'availability',
filterable: false,
minWidth: 200,
- accessor: row => {
- return {
- num_available: row.num_available_segments,
- num_total: row.num_segments,
- };
- },
- Cell: ({ original }) => {
- const { datasource, num_available_segments, num_segments, unused } = original;
-
+ accessor: 'num_segments',
+ Cell: ({ value: num_segments, original }) => {
+ const { datasource, unused, num_segments_to_load } = original;
if (unused) {
return (
@@ -1005,7 +1031,9 @@ ORDER BY 1`;
{pluralIfNeeded(num_segments, 'segment')}
);
- if (num_available_segments === num_segments) {
+ if (typeof num_segments_to_load !== 'number' || typeof num_segments !== 'number') {
+ return '-';
+ } else if (num_segments_to_load === 0) {
return (
@@ -1015,22 +1043,16 @@ ORDER BY 1`;
);
} else {
+ const numAvailableSegments = num_segments - num_segments_to_load;
const percentAvailable = (
- Math.floor((num_available_segments / num_segments) * 1000) / 10
+ Math.floor((numAvailableSegments / num_segments) * 1000) / 10
).toFixed(1);
- const missing = num_segments - num_available_segments;
- const segmentsMissingEl = (
- goToSegments(datasource, true)}>{`${pluralIfNeeded(
- missing,
- 'segment',
- )} unavailable`}
- );
return (
- {num_available_segments ? '\u25cf' : '\u25cb'}
+ {numAvailableSegments ? '\u25cf' : '\u25cb'}
- {percentAvailable}% available ({segmentsEl}, {segmentsMissingEl})
+ {percentAvailable}% available ({segmentsEl})
);
}
@@ -1042,9 +1064,8 @@ ORDER BY 1`;
},
},
{
- Header: twoLines('Segment load/drop', 'queues'),
- show: hiddenColumns.exists('Segment load/drop queues'),
- id: 'load-drop',
+ Header: twoLines('Availability', 'detail'),
+ show: hiddenColumns.exists('Availability detail'),
accessor: 'num_segments_to_load',
filterable: false,
minWidth: 100,
@@ -1069,21 +1090,25 @@ ORDER BY 1`;
accessor: 'avg_segment_rows',
filterable: false,
width: 220,
- Cell: ({ value, original }) => (
- <>
- ;
+ capabilities: Capabilities;
groupByInterval: boolean;
}
@@ -131,6 +134,7 @@ interface SegmentQueryResultRow {
datasource: string;
start: string;
end: string;
+ interval: string;
segment_id: string;
version: string;
time_span: string;
@@ -147,7 +151,6 @@ interface SegmentQueryResultRow {
export interface SegmentsViewState {
segmentsState: QueryState;
- trimmedSegments?: SegmentQueryResultRow[];
segmentFilter: Filter[];
segmentTableActionDialogId?: string;
datasourceTableActionDialogId?: string;
@@ -161,33 +164,74 @@ export interface SegmentsViewState {
export class SegmentsView extends React.PureComponent {
static PAGE_SIZE = 25;
- static WITH_QUERY = `WITH s AS (
- SELECT
- "segment_id", "datasource", "start", "end", "size", "version",
- CASE
- WHEN "start" LIKE '%-01-01T00:00:00.000Z' AND "end" LIKE '%-01-01T00:00:00.000Z' THEN 'Year'
- WHEN "start" LIKE '%-01T00:00:00.000Z' AND "end" LIKE '%-01T00:00:00.000Z' THEN 'Month'
- WHEN "start" LIKE '%T00:00:00.000Z' AND "end" LIKE '%T00:00:00.000Z' THEN 'Day'
- WHEN "start" LIKE '%:00:00.000Z' AND "end" LIKE '%:00:00.000Z' THEN 'Hour'
- WHEN "start" LIKE '%:00.000Z' AND "end" LIKE '%:00.000Z' THEN 'Minute'
- ELSE 'Sub minute'
- END AS "time_span",
- CASE
- WHEN "shard_spec" LIKE '%"type":"numbered"%' THEN 'dynamic'
- WHEN "shard_spec" LIKE '%"type":"hashed"%' THEN 'hashed'
- WHEN "shard_spec" LIKE '%"type":"single"%' THEN 'single_dim'
- WHEN "shard_spec" LIKE '%"type":"none"%' THEN 'none'
- WHEN "shard_spec" LIKE '%"type":"linear"%' THEN 'linear'
- WHEN "shard_spec" LIKE '%"type":"numbered_overwrite"%' THEN 'numbered_overwrite'
- ELSE '-'
- END AS "partitioning",
- "partition_num", "num_replicas", "num_rows",
- "is_published", "is_available", "is_realtime", "is_overshadowed"
- FROM sys.segments
-)`;
-
- private segmentsSqlQueryManager: QueryManager;
- private segmentsNoSqlQueryManager: QueryManager;
+ static baseQuery(hiddenColumns: LocalStorageBackedArray) {
+ const columns = compact([
+ hiddenColumns.exists('Segment ID') && `"segment_id"`,
+ hiddenColumns.exists('Datasource') && `"datasource"`,
+ hiddenColumns.exists('Start') && `"start"`,
+ hiddenColumns.exists('End') && `"end"`,
+ hiddenColumns.exists('Version') && `"version"`,
+ hiddenColumns.exists('Time span') &&
+ `CASE
+ WHEN "start" LIKE '%-01-01T00:00:00.000Z' AND "end" LIKE '%-01-01T00:00:00.000Z' THEN 'Year'
+ WHEN "start" LIKE '%-01T00:00:00.000Z' AND "end" LIKE '%-01T00:00:00.000Z' THEN 'Month'
+ WHEN "start" LIKE '%T00:00:00.000Z' AND "end" LIKE '%T00:00:00.000Z' THEN 'Day'
+ WHEN "start" LIKE '%:00:00.000Z' AND "end" LIKE '%:00:00.000Z' THEN 'Hour'
+ WHEN "start" LIKE '%:00.000Z' AND "end" LIKE '%:00.000Z' THEN 'Minute'
+ ELSE 'Sub minute'
+END AS "time_span"`,
+ hiddenColumns.exists('Partitioning') &&
+ `CASE
+ WHEN "shard_spec" LIKE '%"type":"numbered"%' THEN 'dynamic'
+ WHEN "shard_spec" LIKE '%"type":"hashed"%' THEN 'hashed'
+ WHEN "shard_spec" LIKE '%"type":"single"%' THEN 'single_dim'
+ WHEN "shard_spec" LIKE '%"type":"none"%' THEN 'none'
+ WHEN "shard_spec" LIKE '%"type":"linear"%' THEN 'linear'
+ WHEN "shard_spec" LIKE '%"type":"numbered_overwrite"%' THEN 'numbered_overwrite'
+ ELSE '-'
+END AS "partitioning"`,
+ hiddenColumns.exists('Partition') && `"partition_num"`,
+ hiddenColumns.exists('Size') && `"size"`,
+ hiddenColumns.exists('Num rows') && `"num_rows"`,
+ hiddenColumns.exists('Replicas') && `"num_replicas"`,
+ hiddenColumns.exists('Is published') && `"is_published"`,
+ hiddenColumns.exists('Is available') && `"is_available"`,
+ hiddenColumns.exists('Is realtime') && `"is_realtime"`,
+ hiddenColumns.exists('Is overshadowed') && `"is_overshadowed"`,
+ ]);
+
+ if (!columns.length) {
+ columns.push(`"segment_id"`);
+ }
+
+ return `WITH s AS (SELECT\n${columns.join(',\n')}\nFROM sys.segments)`;
+ }
+
+ static computeTimeSpan(start: string, end: string): string {
+ if (start.endsWith('-01-01T00:00:00.000Z') && end.endsWith('-01-01T00:00:00.000Z')) {
+ return 'Year';
+ }
+
+ if (start.endsWith('-01T00:00:00.000Z') && end.endsWith('-01T00:00:00.000Z')) {
+ return 'Month';
+ }
+
+ if (start.endsWith('T00:00:00.000Z') && end.endsWith('T00:00:00.000Z')) {
+ return 'Day';
+ }
+
+ if (start.endsWith(':00:00.000Z') && end.endsWith(':00:00.000Z')) {
+ return 'Hour';
+ }
+
+ if (start.endsWith(':00.000Z') && end.endsWith(':00.000Z')) {
+ return 'Minute';
+ }
+
+ return 'Sub minute';
+ }
+
+ private segmentsQueryManager: QueryManager;
private lastTableState: TableState | undefined;
@@ -208,194 +252,189 @@ export class SegmentsView extends React.PureComponent {
- const whereParts = filterMap(query.filtered, (f: Filter) => {
- if (f.id.startsWith('is_')) {
- if (f.value === 'all') return;
- return SqlRef.columnWithQuotes(f.id).equal(f.value === 'true' ? 1 : 0);
- } else {
- return sqlQueryCustomTableFilter(f);
+ const {
+ page,
+ pageSize,
+ filtered,
+ sorted,
+ hiddenColumns,
+ capabilities,
+ groupByInterval,
+ } = query;
+
+ if (capabilities.hasSql()) {
+ const whereParts = filterMap(filtered, (f: Filter) => {
+ if (f.id.startsWith('is_')) {
+ if (f.value === 'all') return;
+ return SqlRef.columnWithQuotes(f.id).equal(f.value === 'true' ? 1 : 0);
+ } else {
+ return sqlQueryCustomTableFilter(f);
+ }
+ });
+
+ let queryParts: string[];
+
+ let whereClause = '';
+ if (whereParts.length) {
+ whereClause = SqlExpression.and(...whereParts).toString();
}
- });
- let queryParts: string[];
+ if (groupByInterval) {
+ const innerQuery = compact([
+ `SELECT "start" || '/' || "end" AS "interval"`,
+ `FROM sys.segments`,
+ whereClause ? `WHERE ${whereClause}` : undefined,
+ `GROUP BY 1`,
+ `ORDER BY 1 DESC`,
+ `LIMIT ${pageSize}`,
+ page ? `OFFSET ${page * pageSize}` : undefined,
+ ]).join('\n');
+
+ const intervals: string = (await queryDruidSql({ query: innerQuery }))
+ .map(row => `'${row.interval}'`)
+ .join(', ');
+
+ queryParts = compact([
+ SegmentsView.baseQuery(hiddenColumns),
+ `SELECT "start" || '/' || "end" AS "interval", *`,
+ `FROM s`,
+ `WHERE`,
+ intervals ? ` ("start" || '/' || "end") IN (${intervals})` : 'FALSE',
+ whereClause ? ` AND ${whereClause}` : '',
+ ]);
+
+ if (sorted.length) {
+ queryParts.push(
+ 'ORDER BY ' +
+ sorted
+ .map((sort: any) => `${SqlRef.column(sort.id)} ${sort.desc ? 'DESC' : 'ASC'}`)
+ .join(', '),
+ );
+ }
- let whereClause = '';
- if (whereParts.length) {
- whereClause = SqlExpression.and(...whereParts).toString();
- }
+ queryParts.push(`LIMIT ${pageSize * 1000}`);
+ } else {
+ queryParts = [SegmentsView.baseQuery(hiddenColumns), `SELECT *`, `FROM s`];
- if (query.groupByInterval) {
- const innerQuery = compact([
- `SELECT "start" || '/' || "end" AS "interval"`,
- `FROM sys.segments`,
- whereClause ? `WHERE ${whereClause}` : undefined,
- `GROUP BY 1`,
- `ORDER BY 1 DESC`,
- `LIMIT ${query.pageSize}`,
- query.page ? `OFFSET ${query.page * query.pageSize}` : undefined,
- ]).join('\n');
-
- const intervals: string = (await queryDruidSql({ query: innerQuery }))
- .map(row => `'${row.interval}'`)
- .join(', ');
-
- queryParts = compact([
- SegmentsView.WITH_QUERY,
- `SELECT "start" || '/' || "end" AS "interval", *`,
- `FROM s`,
- `WHERE`,
- intervals ? ` ("start" || '/' || "end") IN (${intervals})` : 'FALSE',
- whereClause ? ` AND ${whereClause}` : '',
- ]);
-
- if (query.sorted.length) {
- queryParts.push(
- 'ORDER BY ' +
- query.sorted
- .map((sort: any) => `${JSONBig.stringify(sort.id)} ${sort.desc ? 'DESC' : 'ASC'}`)
- .join(', '),
- );
- }
+ if (whereClause) {
+ queryParts.push(`WHERE ${whereClause}`);
+ }
- queryParts.push(`LIMIT ${query.pageSize * 1000}`);
- } else {
- queryParts = [SegmentsView.WITH_QUERY, `SELECT *`, `FROM s`];
+ if (sorted.length) {
+ queryParts.push(
+ 'ORDER BY ' +
+ sorted
+ .map((sort: any) => `${SqlRef.column(sort.id)} ${sort.desc ? 'DESC' : 'ASC'}`)
+ .join(', '),
+ );
+ }
- if (whereClause) {
- queryParts.push(`WHERE ${whereClause}`);
- }
+ queryParts.push(`LIMIT ${pageSize}`);
- if (query.sorted.length) {
- queryParts.push(
- 'ORDER BY ' +
- query.sorted
- .map((sort: any) => `${JSONBig.stringify(sort.id)} ${sort.desc ? 'DESC' : 'ASC'}`)
- .join(', '),
+ if (page) {
+ queryParts.push(`OFFSET ${page * pageSize}`);
+ }
+ }
+ const sqlQuery = queryParts.join('\n');
+ setIntermediateQuery(sqlQuery);
+ return await queryDruidSql({ query: sqlQuery });
+ } else if (capabilities.hasCoordinatorAccess()) {
+ let datasourceList: string[] = (await Api.instance.get(
+ '/druid/coordinator/v1/metadata/datasources',
+ )).data;
+
+ const datasourceFilter = filtered.find(({ id }) => id === 'datasource');
+ if (datasourceFilter) {
+ datasourceList = datasourceList.filter(datasource =>
+ booleanCustomTableFilter(datasourceFilter, datasource),
);
}
- queryParts.push(`LIMIT ${query.pageSize}`);
-
- if (query.page) {
- queryParts.push(`OFFSET ${query.page * query.pageSize}`);
+ if (sorted.length && sorted[0].id === 'datasource') {
+ datasourceList.sort(
+ sorted[0].desc ? (d1, d2) => d1.localeCompare(d2) : (d1, d2) => d2.localeCompare(d1),
+ );
}
- }
- const sqlQuery = queryParts.join('\n');
- setIntermediateQuery(sqlQuery);
- return await queryDruidSql({ query: sqlQuery });
- },
- onStateChange: segmentsState => {
- this.setState({
- segmentsState,
- });
- },
- });
- this.segmentsNoSqlQueryManager = new QueryManager({
- processQuery: async () => {
- const datasourceList = (await Api.instance.get(
- '/druid/coordinator/v1/metadata/datasources',
- )).data;
- const nestedResults: SegmentQueryResultRow[][] = await Promise.all(
- datasourceList.map(async (d: string) => {
+ const maxResults = (page + 1) * pageSize;
+ let results: SegmentQueryResultRow[] = [];
+
+ const n = Math.min(datasourceList.length, maxResults);
+ for (let i = 0; i < n && results.length < maxResults; i++) {
const segments = (await Api.instance.get(
- `/druid/coordinator/v1/datasources/${Api.encodePath(d)}?full`,
+ `/druid/coordinator/v1/datasources/${Api.encodePath(datasourceList[i])}?full`,
)).data.segments;
+ if (!Array.isArray(segments)) continue;
+
+ let segmentQueryResultRows: SegmentQueryResultRow[] = segments.map((segment: any) => {
+ const [start, end] = segment.interval.split('/');
+ return {
+ segment_id: segment.identifier,
+ datasource: segment.dataSource,
+ start,
+ end,
+ interval: segment.interval,
+ version: segment.version,
+ time_span: SegmentsView.computeTimeSpan(start, end),
+ partitioning: deepGet(segment, 'shardSpec.type') || '-',
+ partition_num: deepGet(segment, 'shardSpec.partitionNum') || 0,
+ size: segment.size,
+ num_rows: -1,
+ num_replicas: -1,
+ is_available: -1,
+ is_published: -1,
+ is_realtime: -1,
+ is_overshadowed: -1,
+ };
+ });
- return segments.map(
- (segment: any): SegmentQueryResultRow => {
- return {
- segment_id: segment.identifier,
- datasource: segment.dataSource,
- start: segment.interval.split('/')[0],
- end: segment.interval.split('/')[1],
- version: segment.version,
- time_span: '-',
- partitioning: '-',
- partition_num: deepGet(segment, 'shardSpec.partitionNum') || 0,
- size: segment.size,
- num_rows: -1,
- num_replicas: -1,
- is_available: -1,
- is_published: -1,
- is_realtime: -1,
- is_overshadowed: -1,
- };
- },
- );
- }),
- );
+ if (filtered.length) {
+ segmentQueryResultRows = segmentQueryResultRows.filter((d: SegmentQueryResultRow) => {
+ return filtered.every(filter => {
+ return booleanCustomTableFilter(
+ filter,
+ d[filter.id as keyof SegmentQueryResultRow],
+ );
+ });
+ });
+ }
- return nestedResults.flat().sort((d1, d2) => {
- return d2.start.localeCompare(d1.start);
- });
+ results = results.concat(segmentQueryResultRows);
+ }
+
+ return results.slice(page * pageSize, maxResults);
+ } else {
+ throw new Error('must have SQL or coordinator access to load this view');
+ }
},
onStateChange: segmentsState => {
this.setState({
- trimmedSegments: segmentsState.data
- ? segmentsState.data.slice(0, SegmentsView.PAGE_SIZE)
- : undefined,
segmentsState,
});
},
});
}
- componentDidMount(): void {
- const { capabilities } = this.props;
- if (!capabilities.hasSql() && capabilities.hasCoordinatorAccess()) {
- this.segmentsNoSqlQueryManager.runQuery(null);
- }
- }
-
componentWillUnmount(): void {
- this.segmentsSqlQueryManager.terminate();
- this.segmentsNoSqlQueryManager.terminate();
+ this.segmentsQueryManager.terminate();
}
private fetchData = (groupByInterval: boolean, tableState?: TableState) => {
+ const { capabilities } = this.props;
+ const { hiddenColumns } = this.state;
if (tableState) this.lastTableState = tableState;
const { page, pageSize, filtered, sorted } = this.lastTableState!;
- this.segmentsSqlQueryManager.runQuery({
+ this.segmentsQueryManager.runQuery({
page,
pageSize,
filtered,
sorted,
- groupByInterval: groupByInterval,
- });
- };
-
- private fetchClientSideData = (tableState?: TableState) => {
- if (tableState) this.lastTableState = tableState;
- const { page, pageSize, filtered, sorted } = this.lastTableState!;
-
- this.setState(state => {
- const allSegments = state.segmentsState.data;
- if (!allSegments) return {};
- const sortKey = sorted[0].id as keyof SegmentQueryResultRow;
- const sortDesc = sorted[0].desc;
-
- return {
- trimmedSegments: allSegments
- .filter(d => {
- return filtered.every((f: any) => {
- return String(d[f.id as keyof SegmentQueryResultRow]).includes(f.value);
- });
- })
- .sort((d1, d2) => {
- const v1 = d1[sortKey] as any;
- const v2 = d2[sortKey] as any;
- if (typeof v1 === 'string') {
- return sortDesc ? v2.localeCompare(v1) : v1.localeCompare(v2);
- } else {
- return sortDesc ? v2 - v1 : v1 - v2;
- }
- })
- .slice(page * pageSize, (page + 1) * pageSize),
- };
+ hiddenColumns,
+ capabilities,
+ groupByInterval,
});
};
@@ -411,16 +450,10 @@ export class SegmentsView extends React.PureComponent formatBytes(d.size)).concat('(realtime)');
@@ -443,6 +476,15 @@ export class SegmentsView extends React.PureComponent filter.id === 'datasource' && getNeedleAndMode(filter).mode === 'exact',
+ );
+
return (
{
this.setState({ segmentFilter: filtered });
}}
onFetchData={tableState => {
- if (capabilities.hasSql()) {
- this.fetchData(groupByInterval, tableState);
- } else if (capabilities.hasCoordinatorAccess()) {
- this.fetchClientSideData(tableState);
- }
+ this.fetchData(groupByInterval, tableState);
}}
showPageJump={false}
ofText=""
@@ -472,6 +510,8 @@ export class SegmentsView extends React.PureComponent (
String(Boolean(row.is_published)),
Filter: makeBooleanFilter(),
},
{
Header: 'Is realtime',
- show: capabilities.hasSql() && hiddenColumns.exists('Is realtime'),
+ show: hasSql && hiddenColumns.exists('Is realtime'),
id: 'is_realtime',
accessor: row => String(Boolean(row.is_realtime)),
Filter: makeBooleanFilter(),
},
{
Header: 'Is available',
- show: capabilities.hasSql() && hiddenColumns.exists('Is available'),
+ show: hasSql && hiddenColumns.exists('Is available'),
id: 'is_available',
accessor: row => String(Boolean(row.is_available)),
Filter: makeBooleanFilter(),
},
{
Header: 'Is overshadowed',
- show: capabilities.hasSql() && hiddenColumns.exists('Is overshadowed'),
+ show: hasSql && hiddenColumns.exists('Is overshadowed'),
id: 'is_overshadowed',
accessor: row => String(Boolean(row.is_overshadowed)),
Filter: makeBooleanFilter(),
@@ -654,8 +706,7 @@ export class SegmentsView extends React.PureComponent {
- this.segmentsNoSqlQueryManager.rerunLastQuery();
- this.segmentsSqlQueryManager.rerunLastQuery();
+ this.segmentsQueryManager.rerunLastQuery();
}}
>
{`Are you sure you want to drop segment '${terminateSegmentId}'?`}
@@ -666,7 +717,7 @@ export class SegmentsView extends React.PureComponent
@@ -700,11 +751,7 @@ export class SegmentsView extends React.PureComponent
- capabilities.hasSql()
- ? this.segmentsSqlQueryManager.rerunLastQuery(auto)
- : this.segmentsNoSqlQueryManager.rerunLastQuery(auto)
- }
+ onRefresh={auto => this.segmentsQueryManager.rerunLastQuery(auto)}
localStorageKey={LocalStorageKeys.SEGMENTS_REFRESH_RATE}
/>
Group by
@@ -713,11 +760,7 @@ export class SegmentsView extends React.PureComponent {
this.setState({ groupByInterval: false });
- if (capabilities.hasSql()) {
- this.fetchData(false);
- } else {
- this.fetchClientSideData();
- }
+ this.fetchData(false);
}}
>
None
@@ -740,6 +783,10 @@ export class SegmentsView extends React.PureComponent {
+ if (!added) return;
+ this.fetchData(groupByInterval);
+ }}
tableColumnsHidden={hiddenColumns.storedArray}
/>