/
FileEventAdapterConstants.java
94 lines (62 loc) · 4.46 KB
/
FileEventAdapterConstants.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
/*
* Copyright (c) 2017, WSO2 Inc. (http://www.wso2.org) All Rights Reserved.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
package org.wso2.analytics.apim.file.adapter.util;
public final class FileEventAdapterConstants {
public static final String ADAPTER_TYPE_MGW_FILE = "mgwfile";
public static final String ADAPTER_IS_EVENTS_DUPLICATED_IN_CLUSTER_HINT = "events.duplicated.in.cluster.hint";
public static final String API_USAGE_OUTPUT_DIRECTORY = "api-usage-data";
public static final String API_USAGE_FILE_CONTENT = "FILE_CONTENT";
public static final String API_USAGE_OUTPUT_FILE_NAME = "api-usage-data.dat";
public static final String IS_UPLOADED_USAGE_DATA_PUBLISH_ENABLED_PROPERTY = "usage.data.publishing.enabled";
public static final String UPLOADED_USAGE_PUBLISH_FREQUENCY_PROPERTY = "usage.publishing.frequency";
public static final String UPLOADED_USAGE_CLEANUP_FREQUENCY_PROPERTY = "usage.cleanup.frequency";
public static final String FILE_RETENTION_DAYS = "file.retention.days";
public static final String WORKER_THREAD_COUNT_PROPERTY = "microGatewayUsagePublishers";
public static final String DEFAULT_UPLOADED_USAGE_PUBLISH_FREQUENCY = "300000";
public static final String DEFAULT_UPLOADED_USAGE_CLEANUP_FREQUENCY = "3600000";
public static final String INSERT_UPLOADED_FILE_INFO_QUERY = "INSERT INTO AM_USAGE_UPLOADED_FILES "
+ "(TENANT_DOMAIN,FILE_NAME,FILE_TIMESTAMP,FILE_CONTENT) VALUES(?,?,?,?)";
public static final String GET_NEXT_FILES_TO_PROCESS_QUERY_DEFAULT =
"SELECT TENANT_DOMAIN,FILE_NAME,FILE_TIMESTAMP FROM AM_USAGE_UPLOADED_FILES "
+ "WHERE FILE_PROCESSED=0 ORDER BY FILE_TIMESTAMP LIMIT ? FOR UPDATE;";
public static final String GET_NEXT_FILES_TO_PROCESS_QUERY_ORACLE = "SELECT TENANT_DOMAIN,FILE_NAME,FILE_TIMESTAMP "
+ "FROM AM_USAGE_UPLOADED_FILES WHERE rownum<=? AND "
+ "FILE_PROCESSED=0 ORDER BY FILE_TIMESTAMP FOR UPDATE";
public static final String GET_NEXT_FILES_TO_PROCESS_QUERY_MSSQL = "SELECT TOP (?) TENANT_DOMAIN,FILE_NAME,"
+ "FILE_TIMESTAMP FROM AM_USAGE_UPLOADED_FILES WITH (UPDLOCK) "
+ "WHERE FILE_PROCESSED=0 ORDER BY FILE_TIMESTAMP";
public static final String GET_NEXT_FILES_TO_PROCESS_QUERY_DB2 =
"SELECT TENANT_DOMAIN,FILE_NAME,FILE_TIMESTAMP FROM AM_USAGE_UPLOADED_FILES "
+ "WHERE FILE_PROCESSED=0 ORDER BY FILE_TIMESTAMP LIMIT ? FOR UPDATE";
public static final String UPDATE_FILE_PROCESSING_STARTED_STATUS = "UPDATE AM_USAGE_UPLOADED_FILES "
+ "SET FILE_PROCESSED=1 WHERE FILE_PROCESSED=0 AND TENANT_DOMAIN = ? AND FILE_NAME = ?";
public static final String DELETE_OLD_UPLOAD_COMPLETED_FILES = "DELETE FROM AM_USAGE_UPLOADED_FILES "
+ "WHERE (FILE_PROCESSED=1 OR FILE_PROCESSED=2) AND FILE_TIMESTAMP < ?";
public static final String GET_UPLOADED_FILE_CONTENT_QUERY = "SELECT FILE_CONTENT "
+ "FROM AM_USAGE_UPLOADED_FILES WHERE TENANT_DOMAIN=? AND FILE_NAME=?";
public static final String UPDATE_COMPETITION_QUERY = "UPDATE AM_USAGE_UPLOADED_FILES "
+ "SET FILE_PROCESSED=2,FILE_CONTENT=NULL WHERE TENANT_DOMAIN=? AND FILE_NAME=?";
public static final int DEFAULT_WORKER_THREAD_COUNT = 3;
// Separators used for persisting events
public static final String EVENT_SEPARATOR = "--EVT--";
public static final String KEY_VALUE_SEPARATOR = "--KVS--";
public static final String OBJECT_SEPARATOR = "--OBJ--";
public static final String REQUEST_STREAM_ID = "org.wso2.apimgt.statistics.request:1.1.0";
public static final String RESPONSE_STREAM_ID = "org.wso2.apimgt.statistics.response:1.1.0";
public static final String EXECUTION_STREAM_ID = "org.wso2.apimgt.statistics.execution.time:1.0.0";
public static final String FAULT_STREAM_ID = "org.wso2.apimgt.statistics.fault:1.0.0";
public static final String THROTTLE_STREAM_ID = "org.wso2.apimgt.statistics.throttle:1.1.0";
}