sqoop同步时间戳到mysql_在sqoop导入中使用24小时时间戳

我想从使用自由格式查询的oracle导入数据,并且需要以24小时格式存储时间戳。在sqoop导入中使用24小时时间戳

sqoop import --connect jdbc:oracle:thin:(server credntials) \

--username ***** --password ***** \

--query "select emp_uid, emp_name, salary, to_char(create_timestamp, 'YYYY-MM-DD HH24:MI:SS'), to_char(last_sal_update_timestamp, 'YYYY-MM-DD HH24:MI:SS'), coalesce(to_char(last_sal_update_timestamp, 'YYYY-MM-DD HH24:MI:SS'),to_char(create_timestamp, 'YYYY-MM-DD HH24:MI:SS')) as hadoop_import_timestamp from emp.emp_sal where last_sal_update_timestamp < (to_char('2013-01-21 09:16:20', 'YYYY-MM-DD HH24:MI:SS')) and \$CONDITIONS" \

--split-by "to_char(hadoop_import_timestamp, 'YYYY-MM-DD HH24:MI:SS')" \

--target-dir /user/sal/emp_sal \

--map-column-hive CREATE_TIMESTAMP=TIMESTAMP,LAST_SAL_UPDATE_TIMESTAMP=TIMESTAMP,HADOOP_IMPORT_TIMESTAMP=TIMESTAMP \

--hive-import \

--hive-table empdet.empsal \

--hive-drop-import-delims

,但我得到的数字无效错误上尝试运行它

2017-01-11

Venkat

+0

请分享错误日志和蜂巢表结构 –

+0

和Oracle表格plz的描述 –

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/530167.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

mysql权限系统的工作原理_Mysql权限系统工作原理

MySQL权限系统保证所有的用户可以严格地做他们假定被允许做的事情。当你连接一个MySQL服务器时&#xff0c; 你的身份由你从那连接的主机和你指定的用户名来决定&#xff0c;系统根据你的身份和你想做什么来授予权限。MySQL在认定身份中考虑你的主机名和用户名字&#xff0c;是…

mysql日志文件的类型和作用_Mysql日志文件和日志类型介绍_MySQL

日志文件类型MySQL有几个不同的日志文件&#xff0c;可以帮助你找出mysqld内部发生的事情&#xff1a;日志文件记入文件中的信息类型错误日志记录启动、运行或停止mysqld时出现的问题。查询日志记录建立的客户端连接和执行的语句。更新日志记录更改数据的语句。不赞成使用该日志…

ruby mysql 驱动_windows下Rails安装MySql驱动的配置

1.安装ruby这我就不废话了&#xff0c;安装很简单&#xff0c;网上资料也很多。安装完后再环境变量path里加入D:ruby\bin(视你的安装路径了)安装完后在命令行输入ruby -v&#xff0c; 会显示版本号&#xff0c;表示安装成功&#xff0c;我的版本号是1.8.62.安装rails我建议去官…

cross join 一张表没有值关联不出来数据_你是否还在对left join、right join和join有困扰呢?...

说到SQL&#xff0c;很多人可能用了挺久&#xff0c;但依然有个问题一直困扰着&#xff0c;那就是 left join、 join、 right join和 inner join等等各种 join的区别。网上搜&#xff0c;最常见的就是一张图解图&#xff0c;如下&#xff1a;接下来就来实际自己动手实验&#x…

MySQL如何修改表的储存方式_修改mysql默认存储引擎的方法

修改mysql默认存储引擎的方法&#xff0c;供大家学习参考。先来了解一下mysql存储引擎&#xff1a;mysql服务器采用了模块化风格&#xff0c;各部分之间保持相对独立&#xff0c;尤其体现在存储架构上。存储引擎负责管理数据存储&#xff0c;以及mysql的索引管理。通过定义的AP…

前端判断是否安装桌面应用_前端开发人员的桌面应用神器 Electron

01为什么用 JavaScript 来开发桌面应用&#xff1f;曾经的 JavaScript 脆弱、简陋、甚至有被边缘化的危险&#xff0c;不过 JavaScript 在经过了两次飞跃后&#xff08;以 V8 为首的 JavaScript 引擎和 Node.js 的问世&#xff09;&#xff0c;不再受人欺负&#xff0c;早已升级…

mysql 导出csv 多列_从包含300多列的csv,txt或xls文件创建MySQL表

你可以用一些langague C &#xff0c;PHP解析txt文件......然后构建一个请求并执行它。PHP和PDO :: module将使这个最简单。我不知道某个程序是否已经完成这项工作。这是一个解决方案。如果您选择这样做并遇到麻烦&#xff0c;欢迎您。每个stackoverflow成员都会帮助您。编辑&a…

mysql error 1594_【MySQL】解决mysql的 1594 错误-阿里云开发者社区

对于主从架构的mysql,当发生主机断电或者其他原因异常crash的时候, slave的容易发生读取binlog出错的问题&#xff0c;最常见的是show slave status \G;Master_Log_File: mysql-bin.000029Read_Master_Log_Pos: 3154083Relay_Log_File: relay-bin.000478Relay_Log_Pos: 633Rel…

mysql innodb文件_MySQL的InnoDB文件介绍

MySQL一个显著的特点是其可插拔的存储引擎&#xff0c;因此MySQL文件分为两种&#xff0c;一种是和MySQL数据库本身相关 的文件&#xff0c;一种是和存储引擎相关的文件。本文主要介绍和InnoDB存储引擎相关的文件。表空间文件InnoDB在存储上也模仿了Oracle的设计&#xff0c;数…

python中与label类似的控件是_python中tkinter的使用(控件整理)(一)

1、使用tkinter.Tk() 生成主窗口(windowtkinter.Tk())&#xff1a;window.title(标题名)修改框体的名字,也可在创建时使用className参数来命名&#xff1b;window.resizable(0,0)框体大小可调性&#xff0c;分别表示x,y方向的可变性&#xff1b;1表示可变&#xff0c;0表示不可…

jdbc dao 工具类mysql_Java基于JDBC实现事务,银行转账及货物进出库功能示例

本文实例讲述了Java基于JDBC实现事务&#xff0c;银行转账及货物进出库功能。分享给大家供大家参考&#xff0c;具体如下&#xff1a;1. 转账业务转账必须执行2个sql语句(update更新)都成功的情况下&#xff0c;提交事务&#xff0c;如果有一个失败&#xff0c;则2个都回滚事务…

冒险岛单机版mysql_冒险岛单机版

这款《冒险岛单机版》经验是盛大冒险岛的100倍?最新盛大地图及BOSS&#xff0c;甚至包括盛大没有地图BOSS及现金装备&#xff0c;地图包括新加坡&#xff0c;马来西亚&#xff0c;台湾&#xff0c;可口可乐城&#xff0c;闹鬼宅邸&#xff0c;暹罗等等?。25驾坐骑&#xff0c…

python与html5搭建聊天室_html5 websocket 新版协议聊天室 服务端(python版)

网上找了很多代码都是旧版协议的&#xff0c;研究了很久终于弄清楚了 现在发个用新版协议写的服务端代码出来(这个代码是从网上旧版协议改过来的)最要就是握手协议和发送接受字符的方式变了# incodingutf-8import socketimport structimport hashlibimport threading,randomimp…

mysql数据库开发笔记_MySQL数据库生成数据库说明文档

在半年多前为一个MySQL数据库生成过数据库说明文档&#xff0c;今天要重新生成一份&#xff0c;但是发现完全不记得当时是怎么生成的&#xff0c;只能在网上搜索重来一遍&#xff0c;所以今天特意把这个过程记录一下。一、安装使用MySQL数据库表结构导出器DBExportDoc V1.0 For…

java 字符串缓冲区_详解Java中字符串缓冲区StringBuffer类的使用

StringBuffer 是一个线程安全的可变的字符序列。它继承于AbstractStringBuilder&#xff0c;实现了CharSequence接口。StringBuilder 也是继承于AbstractStringBuilder的子类&#xff1b;但是&#xff0c;StringBuilder和StringBuffer不同&#xff0c;前者是非线程安全的&#…

rabbitmq java文档_RabbitMQ文档翻译——Hello World!(上)

文章主要翻译自RabbitMQ官方文档&#xff0c;主要是为了练习英语翻译&#xff0c;顺便学习一下RabbitMQ&#x1f636;其中也记录了一些爬过的坑IntroductionRabbitMQ is a message broker. The principal idea is pretty simple: it accepts and forwards messages. You can th…

java string 包含http_Java中使用HttpPost上传文件以及HttpGet进行API请求(包含HttpPost上传文件)...

一、HttpPost上传文件public static String getSuffix(final MultipartFile file){if(file null || file.getSize() 0){return null;}String fileName file.getOriginalFilename();return fileName.substring(fileName.lastIndexOf(".")1);}public static JSONObj…

java倒计时跳出窗口_java倒计时弹出框

直接使用java语言写出一个运行时的弹出框倒计时&#xff1a;package test.dagong.testDecreaseDate;import java.awt.Container;import java.awt.FlowLayout;import java.awt.Toolkit;import java.awt.event.ActionEvent;import java.awt.event.ActionListener;import javax.sw…

jpa mysql存储过程_Jpa调用存储过程及参数

public List findAllEntityListBySearch(Long inputInfoId, int flag) throws Exception {List infoviewListnew ArrayList<>();EntityManager em emf.createEntityManager();try {StoredProcedureQuery storedProcedure em.createStoredProcedureQuery("存储名称&…

python从mongodb里取出数据进行可视化_python3 mongoDB数据库的安装配置与可视化

python3 mongoDB数据库的安装配置与可视化。前天说是要学习如何使用mongoDB的链接与安装。安装环境&#xff1a; wind10 还是盗版的 磁盘分析&#xff1a;只有一个C盘&#xff0c;步骤&#xff1a;1 . 下载这里下载了对应的msi文件&#xff0c;貌似.zip文件没有了2 我默认把mon…